Spring Kafka集成测试非首次执行时失败问题求助

• 确保Kafka容器与Topic的隔离性
  不要复用Testcontainers Kafka容器，每次测试启动全新实例，可通过withReuse(false)关闭容器复用；同时给测试用的Topic添加唯一标识（比如拼接随机UUID或测试类名），避免不同测试间的Topic数据干扰。例如动态生成Topic名称：SCHEDULE_RAW_TOPIC-${UUID.randomUUID()}，让生产者和消费者统一使用这个动态名称。

• 优化消费者的等待与偏移量配置

  • 消费者初始化或消息投递存在延迟时，不要用固定时长的休眠等待，改用CountDownLatch配合超时等待：生产者发送消息后调用send().get(5, TimeUnit.SECONDS)确保发送确认；消费者收到消息时触发countDown()，测试代码中通过latch.await(10, TimeUnit.SECONDS)等待消息，超时后再判断结果。
  • 配置消费者auto.offset.reset=earliest，确保消费者启动时从头消费Topic消息，避免因历史偏移量导致漏消费。可在测试专用的application.properties中添加该配置。

• 调整Spring上下文的清理策略
  若@DirtiesContext无效，可指定清理模式为@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)，确保每个测试方法执行后都清理上下文；同时检查其他测试类是否复用了上下文，必要时给相关测试类也添加该注解，避免Bean状态残留。还可将Kafka相关测试配置抽成独立的@TestConfiguration类，在测试类中通过@Import导入，保证每次测试加载全新配置。

• 排查生产者的发送确认配置
  配置生产者acks=all，确保消息被Kafka Broker确认后再返回，避免消息丢失；同时确认生产者和消费者的bootstrap-servers都正确指向Testcontainers提供的地址（通过kafka.getBootstrapServers()获取），而非本地固定地址。

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