如何知道kafka-spring云流中是否消耗了所有消息

Question

我们正在有条件地触发Kafka消费者。如何知道该主题的所有消息是否已被使用。

Answer 1

可以使用一个ListenerContainerCustomizer@Bean来配置侦听器容器上的idleEventInterval，使用一个@EventListener方法来消耗容器的空闲事件。

看到https://docs.spring.io/spring-kafka/docs/current/reference/html/idle-containers

和

https://docs.spring.io/spring-cloud-stream/docs/3.1.4/reference/html/spring-cloud-stream.html _advanced_consumer_configuration