返回到文章

采纳

编辑于 3年前

kafka消费者消费一段时间就自动停止消费

kafka

我是使用的类似于kettle的kafka消费者组件,在正常运行一段时间后,kafka就停止了消费,期间没有报错,另外重启任务,其又能正常的进行消息的消费。

其中的参数如下:

auto.offset.reset  earliest
session.timeout.ms 20000

我的怀疑是一段时间内kafka中没有消息,消费者一直消费不到消息,导致消费者被踢出消费群组。

重启前和后:

kafka消费者:

希望给出解答。