如何知道是否所有消息都在kafka-spring云流中被消费

Question

我们正在有条件地触发 Kafka 消费者。如何知道topic的所有消息是否都被消费了。

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