这家伙太懒,什么都没留下
没报错,我很难帮你分析额。我是觉得你消费者是不是抛出异常,导致poll(100)中断了。
我重启程序之后就正常消费,这个问题也不出现了,随机性也很大,日志上也没有报错
是的 我用这个条命令./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group 发现消费者不在了。这个情况是偶尔出现 ,我程序还在正常跑着,在kafka上已经没有我的消费者了。
没有任何错误信息?
我的服务一直给kfka发送消息,消费者突然不能消费消息了,数据也在kafka里面存着,就是消费不到。但是我重启服务之后就能正常消费 而且之前的数据也没有丢失。