这个问题太简单了。。。
大神 能告诉下 是什么原因吗 我就是会偶尔出现这样的问题 看日志也没有错误
不是,我是说你这问题提的太简单了,我无从下手。。你场景描述下,什么情况下丢失消息。
我的服务一直给kfka发送消息,消费者突然不能消费消息了,数据也在kafka里面存着,就是消费不到。但是我重启服务之后就能正常消费 而且之前的数据也没有丢失。
没有任何错误信息?
是的 我用这个条命令./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group 发现消费者不在了。这个情况是偶尔出现 ,我程序还在正常跑着,在kafka上已经没有我的消费者了。
我重启程序之后就正常消费,这个问题也不出现了,随机性也很大,日志上也没有报错
没报错,我很难帮你分析额。我是觉得你消费者是不是抛出异常,导致poll(100)中断了。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
这个问题太简单了。。。
大神 能告诉下 是什么原因吗 我就是会偶尔出现这样的问题 看日志也没有错误
不是,我是说你这问题提的太简单了,我无从下手。。
你场景描述下,什么情况下丢失消息。
我的服务一直给kfka发送消息,消费者突然不能消费消息了,数据也在kafka里面存着,就是消费不到。但是我重启服务之后就能正常消费 而且之前的数据也没有丢失。
没有任何错误信息?
是的 我用这个条命令./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group 发现消费者不在了。这个情况是偶尔出现 ,我程序还在正常跑着,在kafka上已经没有我的消费者了。
我重启程序之后就正常消费,这个问题也不出现了,随机性也很大,日志上也没有报错
没报错,我很难帮你分析额。
我是觉得你消费者是不是抛出异常,导致poll(100)中断了。
你的答案