java - Spring Kafka - 防止消费者在 Spring Boot 构建期间连接 Kafka 主题

Question

我在容器工厂上执行了 autoStartup(false)，但不确定应该在何处注入(inject) KafkaListenerEndpointRegistry。

我不希望消费者在构建时连接。它应该在 spring boot 应用程序完全启动后连接 Kafka 主题。

Answer 1

您应该使用 KafkaListener 注释方法在类中注入(inject) KafkaListenerEndpointRegistry 因为来自文档

The listener containers created for @KafkaListener annotations are not beans in the application context. Instead, they are registered with an infrastructure bean of type KafkaListenerEndpointRegistry

因此，通过使用此 KafkaListenerEndpointRegistry 实例，您可以管理容器启动/停止的生命周期 here

示例:

@Autowired
private KafkaListenerEndpointRegistry registry;

   ...

 @KafkaListener(id = "myContainer", topics = "myTopic", autoStartup = "false")
 public void listen(...) { ... }

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