Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？![Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？-[阿里云_云淘科技]](http://www.cnzhanzhang.com/wp-content/uploads/2024/01/20240111120922-659fda7233ce5.png)
![Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？-[阿里云_云淘科技]](https://www.cnzhanzhang.com/wp-content/themes/justnews/themer/assets/images/lazy.png)
以下为热心网友提供的参考意见
从你给出的日志来看，问题是关于Kafka消费者未能获取足够的offsets而导致程序挂起。这种现象通常发生在消费者的偏移量设置不正确的情况下。
首先，你需要确认一下这两个Consumer实例所对应的Topic名称以及Group ID是否一致。如果不是的话，可能会出现一个Consumer实例已经读取到了某个特定位置的数据，但另一个却还在等待初始Offset的位置上。
其次，查看下这两个Consumer实例的group.id属性是否相同。因为每个不同的组ID对应的是不同的消息队列分区，所以不同组内的Consumer应该有不同的偏移量设定才能正常工作。
最后，建议你在生产环境中添加一些额外的信息以便于定
本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/22120.html