如何停止一个服务或Kafka消费者后,它已经闲置了一段时间?

n7taea2i  于 2022-11-21  发布在  Apache
关注(0)|答案(1)|浏览(101)

我有一个Kafka消费者作为服务持续运行。我注意到它在一天中只运行一段时间。我不想让它持续运行,而是想为消费者设置某种轮询超时。
如果消费者在10分钟内没有消费任何东西/空闲,那么我想关闭服务。是否有某种轮询超时和信号机制,比如Kafka中的这种机制,我可以使用?

c9qzyr3d

c9qzyr3d1#

参见ListenerContainerIdleEvent和各自的容器属性及其文档:https://docs.spring.io/spring-kafka/docs/current/reference/html/#idleEventInterval

相关问题