使用 spring-kafka 在一天中的特定时间消费主题

Question

我们需要在一天中的特定时间使用来自特定主题的数据，我们希望我们的 kafka 侦听器仅在一天中的那个时间为特定主题工作。

正在阅读 Kafka Scheduler 的文章 https://jaceklaskowski.gitbooks.io/apache-kafka/kafka-KafkaScheduler.html

感谢任何其他方法或对使用 Kafka 调度程序的任何帮助。 我们将使用 spring kafka 1.3.10.RELEASE 版本

Answer 1

自动装配 KafkaListenerEndpointRegistry 并调用 start()/stop() 到 start/stop 所有容器。

您还可以使用 registry.getListenerContainer("foo").start() 启动具有特定 id 的容器。

在容器上将 autoStartup 设置为 false，这样 Spring 就不会在启动时自动启动它们。