在生产环境部署kafka集群和消费者服务器后，通过logstash向kafka集群发送实时日志，消费者也能正常消费信息。但是两分钟之后消费者就停止消费信息了，想问下各位老师如何排查问题点在哪里。
1：查看了kafka服务器的日志，logstash还在向kafka推实时日志，kafka集群日志留存时间是两个小时。
2：kafka消费者一共有两台，两台都在同时运行。
3：kafka集群有三台服务器，查问题的时候发现，kafka消费者只连接到了一台broker上，不知道这是不是原因所在。
不知道你这个问题是否已经解决, 如果还没有解决的话: