我正在使用高级消费者，如下所述：https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
我注意到我的消费者不会永远运行并在一段时间后结束 . 在zookeeper方面，我看到以下内容：
INFO sessionid的已处理会话终止：0x144a4854325004d（org.apache.zookeeper.server.PrepRequestProcessor）INFO客户端/127.0.0.1:59899的已关闭套接字连接，其中包含sessionid 0x144a4854325004d（org.apache.zookeeper.server.NIOServerCnxn）
我正在使用默认配置 . 如何让我的消费者永远倾听？
1 回答
您可能想尝试运行ConsoleConsumer .