为何KafkaListenerEndpointRegistry中无@KafkaListener对应的容器？

以下是几种可能导致KafkaListenerEndpointRegistry.getAllContainers()返回空的原因及对应解决方案：

1. 未启用Kafka监听器注解支持 #

Spring不会自动识别@KafkaListener注解，必须在配置类上添加@EnableKafka注解，开启对该注解的扫描与处理：

@Configuration
@EnableKafka
public class KafkaConfig {
    // 可在此配置KafkaListenerContainerFactory等相关Bean
}

2. TestListener未被Spring容器管理 #

你的TestListener类没有添加Spring组件注解（如@Component、@Service），Spring无法扫描到这个类，也就不会为其中的@KafkaListener方法创建监听器容器。修改如下：

@Component
public class TestListener {

  @KafkaListener(id = "test", idIsGroup = false, topics = {"com.org.testing"})
  public void subscribe(String message) {

  }

}

3. 调用时机过早 #

如果在Spring应用上下文完全初始化完成前调用getAllContainers()，此时监听器容器还未被注册到KafkaListenerEndpointRegistry中。确保在上下文刷新完成后再执行相关操作，比如通过监听ContextRefreshedEvent事件：

@Component
public class Command {
  @Autowired
  private KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry;  

  @EventListener(ContextRefreshedEvent.class)
  public void test() {
    this.kafkaListenerEndpointRegistry.getAllContainers(); // 此时容器已完成注册
  }

}

4. 缺少必要的Kafka容器工厂配置 #

如果没有正确配置KafkaListenerContainerFactory，Spring无法创建监听器容器。可以在配置类中定义该Bean：

@Configuration
@EnableKafka
public class KafkaConfig {

    @Value("${spring.kafka.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        return new DefaultKafkaConsumerFactory<>(props);
    }

    @Bean
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }
}

内容的提问来源于stack exchange，提问作者Steven Kristian