Spring Boot使用EmbeddedKafka测试Kafka组件全量构建超时失败如何解决

• 全量构建时多个标注@EmbeddedKafka的测试类共享Spring上下文缓存，前序测试启动的Embedded Kafka实例未销毁，同名topic已被创建且配置（如分区数）与当前测试指定的不一致，你日志中显示分配了2个分区但测试类指定分区数为1，就是这个问题的直接表现。
• 消费者默认auto.offset.reset配置为latest，若测试执行时消息发送早于消费者分区分配完成，消费者会直接跳过已发送的消息，导致awaitility等待超时报错。
• 若WageEvent未正确重写equals和hashCode方法，equalTo匹配会直接对比对象引用而非字段值，也会触发超时。

1. 上下文隔离配置
   给所有带@EmbeddedKafka的测试类添加@DirtiesContext注解，测试执行完成后直接销毁当前上下文，关闭Embedded Kafka实例，彻底避免多测试之间的实例、topic冲突。
   修改后的测试类头如下：

@SpringBootTest(properties = { 
    "kafka.wages-topic.bootstrap-address=${spring.embedded.kafka.brokers}",
    "spring.kafka.consumer.auto-offset-reset=earliest"
})
@EmbeddedKafka(partitions = 1, topics = "${kafka.wages-topic.name}")
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
class KafkaPublisherTest {
    // 原有测试逻辑
}

这里额外添加了auto.offset.reset=earliest配置，保证消费者启动后能拉取到所有之前发送的消息。

2. 确认消息发送时机
   在发送测试消息前先等待消费者完成分区分配，避免消息早于消费者上线丢失：

@Autowired
private KafkaMessageListenerContainer<String, WageEvent> wageListenerContainer;

@BeforeEach
void waitForPartitionAssignment() {
    TestUtils.waitForAssignment(wageListenerContainer, 1);
}

3. 检查对象匹配逻辑
   确认WageEvent类已正确重写equals和hashCode方法，所有参与匹配的字段都已纳入对比规则。

如果项目中Kafka相关测试较多，推荐使用Testcontainers替代@EmbeddedKafka：

• 每个测试启动独立的Kafka容器，隔离性更强，完全避免多测试之间的环境冲突
• 测试环境和生产环境Kafka版本、行为完全一致，测试结果可信度更高
• 不需要处理上下文缓存、实例销毁等嵌入式Kafka特有的问题

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