Java Kafka Consumer - 消费者超时

Question

我正在尝试构建一个 Kafka Consumer，预计其存活时间约为 60 分钟。也就是说，轮询消息 60 分钟，然后退出轮询主题。是否有任何属性定义此用例的超时？或者我应该引入编程方法来在特定时间后停止轮询？

Kafka Consumer 在一定时间后停止轮询。

Answer 1

如果您使用 Spring（这就是您标记的），您可以随时停止/启动侦听器容器。

没有任何内置功能可以在一段时间后自动停止。

Answer 2

任何人都可以解释为什么我们不能调用consumer.close();经过 1 小时的轮询并处理消息后在这里？