如何知道所有消息是否在卡夫卡-春泉云流中被消费

问题描述

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

推荐答案

您可以使用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