Потребление от темы в определенное время в течение дня, используя Spring-Kafka

Question

Нам нужно использовать данные из определенной темы в определенное время в течение дня, мы хотим, чтобы наш слушатель kafka работал только в это время дня для определенной темы.

Проходил черезстатья Kafka Scheduler https://jaceklaskowski.gitbooks.io/apache-kafka/kafka-KafkaScheduler.html

Любой другой подход или любая помощь в использовании Kafka планировщика приветствуется. Мы будем использовать весеннюю кафку 1.3.10. РЕЛИЗОВАЯ версия

Answer 1

Автоматически подключите KafkaListenerEndpointRegistry и позвоните start()/stop(), чтобы запустить / остановить все контейнеры.

Вы также можете использовать registry.getListenerContainer("foo").start() для запуска контейнера с определенным id.

Установите autoStartup в false для контейнеров, чтобы Spring не запускал их автоматически при запуске.