Spring测试类访问@Autowired Kafka组件变量偶发为空问题排查

• 核心原因：Spring测试上下文缓存导致多Kafka监听器实例并存，实际消费消息的实例并非测试中注入的实例。
  Spring Test默认会按测试配置维度缓存应用上下文，只要不同测试类的profile、启动配置、属性参数存在差异，就会创建新的上下文实例。旧上下文如果没有被显式销毁，其内部初始化的KafkaListener容器会一直保持运行，和新上下文中的消费者共同订阅目标主题，触发消费者组重平衡。
  由于Kafka主题单分区默认只会分配给同组内的一个消费者实例，你日志中看到的「消费成功、写入集合」的输出，本质是旧上下文中未销毁的KafkaConsumer实例打印的——它把消息写入了自己持有的集合，和你当前测试类注入的KafkaConsumer实例根本不是同一个对象。你在@Before/@After里调用的emptyConsumer()也只能清空当前测试实例持有的集合，碰不到旧实例里的数据，自然轮询到超时都是空。
• 次要诱因：消息存储集合存在并发缺陷
  @KafkaListener的消费逻辑运行在独立的Kafka消费者线程池，和测试主线程、Awaitility轮询线程不属于同一个线程。如果你使用非线程安全的ArrayList存储消息，且没有做任何可见性保障，JVM可能因为CPU缓存、指令重排序的优化，导致测试线程始终读取到消费线程写入前的空集合状态，哪怕写入操作的时间戳早于轮询开始时间。

• 解决多消费者实例抢占消息问题
  • 在测试基类上添加@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)注解，标记每个测试类执行完成后就关闭关联的应用上下文，销毁其中运行的Kafka监听器容器，避免旧实例残留。如果单测试方法间存在互相干扰，可以调整为AFTER_EACH_TEST_METHOD模式，只是测试执行速度会稍慢。
  • 给测试环境的消费者组配置动态唯一标识，避免不同上下文的消费者属于同一个消费组抢占分区。可以在测试配置文件中添加配置：spring.kafka.consumer.group-id=test-consumer-${random.uuid}，每个上下文启动时都会生成独立的groupId，不会触发跨上下文的重平衡。
  • 快速验证方式：在@KafkaListener消费方法中打印当前KafkaConsumer实例的hashCode，同时在测试方法中打印注入的KafkaConsumer实例的hashCode，两个值不一致就能直接确认是多实例问题。
• 解决并发可见性与线程安全问题
  • 将存储消费消息的List<String>替换为线程安全的CopyOnWriteArrayList实现，不要使用普通的ArrayList。
  • 存储集合的字段添加volatile修饰，清空集合时直接调用集合的clear()方法，不要通过new ArrayList<>()重新赋值，避免引用替换带来的可见性问题。
  • 提供专门的同步方法获取已消费消息的数量/内容，不要直接在测试代码中读取公共集合字段，避免并发修改异常和可见性问题。

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