kafka消费者无法消费信息

Question

在生产环境部署kafka集群和消费者服务器后，通过logstash向kafka集群发送实时日志，消费者也能正常消费信息。但是两分钟之后消费者就停止消费信息了，想问下各位老师如何排查问题点在哪里。

1：查看了kafka服务器的日志，logstash还在向kafka推实时日志，kafka集群日志留存时间是两个小时。

2：kafka消费者一共有两台，两台都在同时运行。

3：kafka集群有三台服务器，查问题的时候发现，kafka消费者只连接到了一台broker上，不知道这是不是原因所在。

Answer 1

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 建议你看下这篇博客👉 ：kafka消费者从kafka读取信息

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^