如何暂停Kafka消费者的投票行为？

Question

我想在特定时间停止对特定主题的轮询。

• Spring防尘套2.X
• Springkafka 2.5.5
• Kafka版本2.5.1

比如即使有消息进来测试题目分区，消息也是从00到01堆在分区里，没有消耗。

01点之后，我想再次使用有关TEST主题的消息。

如何暂停和恢复？

Answer 1

使用KafkaListenerEndpointRegistrybean控制侦听器容器的生命周期；你可以根据你想要的任何条件停止和启动它们。

您还可以将它们配置为在您明确启动它们之前处于停止状态。

请参阅 https://docs.spring.io/spring-kafka/docs/current/reference/html/#kafkalistener-lifecycle。

java prettyprint-override">@KafkaListener(id = "myContainer", topics = "myTopic", autoStartup = "false")
public void listen(...) { ... }

和

@Autowired
private KafkaListenerEndpointRegistry registry;

...

    this.registry.getListenerContainer("myContainer").start();

...