Блог

Мы запускаем потребителя Kafka на условной основе. Как узнать, используются ли все сообщения темы.

Вы можете использовать a 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