返回到文章

采纳

编辑于 1年前

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

kafka

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

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

kafka版本kafka_2.11-2.2.0