消费者没有正确断开连接

Question

我写了一个连接到 Kafka 的节点进程，创建一个消费者，读取一些消息并在读取整个主题后返回这些消息。 但是我无法正确断开连接。第一个屏幕截图显示了我的控制台输出。第二个屏幕截图显示了生成它的代码。

问题是消费者根本没有断开连接。即使在约 20 分钟后，第二条日志消息也不会触发，所以我猜它一定是遇到了错误。 如果你们中有人知道发生了什么，请告诉我。