Spring Boot+Spring Kafka+TestContainers项目中第二个Kafka监听器的来源疑问

兄弟，我太懂你遇到的这个糟心问题了——搭项目的时候好好的，突然冒出来个额外的Kafka监听器，找半天不知道哪来的。结合你给出的不完整TestContainers配置（我先帮你补全合理的部分），给你拆解下几个最可能的原因：

你当前的TestContainers配置片段（补全未完成的合理部分）：

private static final Network NETWORK = Network.newNetwork();    

@Bean   
@ServiceConnection   
public ConfluentKafkaContainer kafkaContainer() {   
  return new ConfluentKafkaContainer(   
          DockerImageName.parse("confluentinc/cp-kafka:7.9.0")   
              .asCompatibleSubstituteFor("apache/kafka"))   
      .withNetwork(NETWORK)
      .withExposedPorts(9092); // 补全常见的Kafka端口配置
}

第一个可能：TestContainers+@ServiceConnection的自动配置搞的鬼 #

当你用@ServiceConnection注解时，Spring Boot会自动把Kafka容器的连接参数注入到上下文里，但ConfluentKafkaContainer本身启动时，会给容器内部的Kafka实例注册一个内部通信监听器，同时Spring Boot的自动配置又会基于容器暴露的端口生成一个外部访问的监听器——这俩叠加起来，就会出现两个监听器的情况，很多人第一次用这套组合都会踩这个坑。

第二个可能：Spring Kafka自动配置生成的默认监听器 #

如果你项目里引了spring-kafka-starter，Spring Boot的KafkaAutoConfiguration自动配置类会默认给你生成一个KafkaListenerContainerFactory，这个工厂会自动扫描你代码里的@KafkaListener注解。要是你的TestContainers配置没完全覆盖默认的Kafka连接参数，就会触发这个默认工厂实例化出一个额外的监听器。

第三个可能：测试上下文和主上下文重复加载 #

有没有可能你在测试类里既用了@SpringBootTest（会加载主项目的上下文配置），又在测试类里手动配置了Kafka容器？这种情况下主上下文和测试上下文各生成一套监听器，自然就有两个了。

给你几个排查和解决的小妙招 #

1. 先搞清楚监听器的具体来源
   在测试类里加一段代码，启动时打印所有Kafka监听器的Bean信息，一眼就能定位根源：

   @Autowired
   private ApplicationContext context;
   
   @BeforeEach
   void checkKafkaListeners() {
     Map<String, KafkaListenerEndpointRegistry> registries = context.getBeansOfType(KafkaListenerEndpointRegistry.class);
     registries.forEach((name, registry) -> {
       System.out.println("监听器注册表名称: " + name);
       registry.getListenerContainers().forEach(container -> {
         System.out.println("监听器容器ID: " + container.getListenerId() + ", 所属Bean: " + container.getBeanName());
       });
     });
   }
   

2. 关掉多余的自动配置
   要是你不需要Spring Kafka的默认监听器，可以在测试类上加上@EnableAutoConfiguration(exclude = {KafkaAutoConfiguration.class})，然后自己手动配置需要的监听器容器工厂。
3. 确保配置唯一
   检查下项目里是不是有多个地方配置了Kafka容器或者@ServiceConnection，把重复的删掉，只留一个核心配置就行。

备注：内容来源于stack exchange，提问作者Lee Theobald