我正在尝试构建一个Kafka Consumer，它预计将保持活动状态约60分钟。也就是说，轮询消息60分钟，然后退出轮询主题。是否有任何属性定义此用例的超时？或者我应该引入编程方法来在特定时间后停止轮询？Kafka Consumer在一定时间后停止轮询。
e4eetjau1#
如果您使用Spring（这就是您标记的），您可以随时停止/启动侦听器容器。没有任何内置的东西可以在一段时间后自动停止。
1条答案
按热度按时间e4eetjau1#
如果您使用Spring（这就是您标记的），您可以随时停止/启动侦听器容器。
没有任何内置的东西可以在一段时间后自动停止。