我有一个Kafka消费者作为服务持续运行。我注意到它在一天中只运行一段时间。我不想让它持续运行,而是想为消费者设置某种轮询超时。如果消费者在10分钟内没有消费任何东西/空闲,那么我想关闭服务。是否有某种轮询超时和信号机制,比如Kafka中的这种机制,我可以使用?
c9qzyr3d1#
参见ListenerContainerIdleEvent和各自的容器属性及其文档:https://docs.spring.io/spring-kafka/docs/current/reference/html/#idleEventInterval
ListenerContainerIdleEvent
1条答案
按热度按时间c9qzyr3d1#
参见
ListenerContainerIdleEvent
和各自的容器属性及其文档:https://docs.spring.io/spring-kafka/docs/current/reference/html/#idleEventInterval