采纳
我是使用的类似于kettle的kafka消费者组件,在正常运行一段时间后,kafka就停止了消费,期间没有报错,另外重启任务,其又能正常的进行消息的消费。
其中的参数如下:
auto.offset.reset earliest session.timeout.ms 20000
我的怀疑是一段时间内kafka中没有消息,消费者一直消费不到消息,导致消费者被踢出消费群组。
重启前和后:
kafka消费者:
希望给出解答。