Kafka消费一段时间后,就停止消费了,消费者端也不报错。

焚@ 发表于: 2023-08-30   最后更新时间: 2023-08-30 15:21:21   886 游览

kafka消费数据时刚开始消费正常,消费一段时间之后就停止消费了。消费者端也不报错。

我是用的是Consumer.assign(),指定topic和分区,进行手动offset提交,并进行redis存储offset。

kafka版本kafka_2.11-2.2.0

发表于 2023-08-30
添加评论

应该是你的程序写的不健壮导致的,检查下程序。
例如:消费者的这个线程被释放了

你的答案

查看kafka相关的其他问题或提一个您自己的问题