我使用的是高级消费者，如以下所述：https://cwiki.apache.org/confluence/display/kafka/consumer+group+example
我注意到，我的消费者不会永远运行，并在一段时间后结束。在zookeeper方面，我看到了以下内容：
sessionid:0x144a4854325004d（org.apache.zookeeper.server.prerequestprocessor）的会话终止信息已处理
info已关闭客户端/127.0.0.1:59899的套接字连接，会话ID为0x144a4854325004d（org.apache.zookeeper.server.nioservercnxn）
我使用的是默认配置。如何让我的消费者永远倾听？