采纳
kafka消费数据时刚开始消费正常,消费一段时间之后就停止消费了。消费者端也不报错。
我是用的是Consumer.assign(),指定topic和分区,进行手动offset提交,并进行redis存储offset。
kafka版本kafka_2.11-2.2.0