Spring Boot @EmbeddedKafka测试并行运行失败如何解决？

核心问题分析 #

• 端口冲突：所有测试硬编码localhost:9092端口，并行运行时多个EmbeddedKafka实例抢占同一端口，直接触发资源访问异常。
• 主题数据串扰：部分测试向相同主题发送数据，并行执行时不同测试的消息会互相干扰，破坏测试的独立性和预期结果。

具体解决方案 #

1. 取消端口硬编码，使用随机端口 #

去掉brokerProperties中的固定端口配置，改为让系统自动分配空闲端口，彻底避免端口冲突：

@SpringBootTest
@DirtiesContext
@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:0", "port=0" })
class SampleIntegrationTest extends BaseIntegrationTest {
   // 测试代码
}

Spring Boot会自动将spring.kafka.bootstrap-servers配置为当前EmbeddedKafka实例的实际端口，无需在生产者/消费者中硬编码地址。如果是自定义Kafka客户端，可通过注入EmbeddedKafkaBroker获取端口：

@Autowired
private EmbeddedKafkaBroker embeddedKafkaBroker;

// 获取当前实例的bootstrap地址
String bootstrapServers = embeddedKafkaBroker.getBrokersAsString();

2. 为每个测试实例隔离主题 #

方案一：动态生成唯一主题名

在测试类中结合随机字符串或测试类名生成专属主题，确保不同测试的消息不会串扰：

@SpringBootTest
@DirtiesContext
@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:0", "port=0" })
class SampleIntegrationTest extends BaseIntegrationTest {
    private static final String TEST_TOPIC = "test-topic-" + UUID.randomUUID().toString().substring(0, 8);

    // 生产者/消费者统一使用TEST_TOPIC
}

方案二：强化上下文隔离

你已经使用的@DirtiesContext注解会在测试类执行完毕后销毁Spring上下文，连带清理当前实例的Kafka主题、消息等资源。不过该注解会增加测试总耗时，需根据实际场景权衡使用。

3. 按需调整JUnit并行策略（可选） #

如果部分Kafka测试确实无法完全隔离，可以针对单个测试类指定串行执行，不影响其他测试的并行效率：

@SpringBootTest
@DirtiesContext
@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:0", "port=0" })
@Execution(ExecutionMode.SAME_THREAD)
class SampleIntegrationTest extends BaseIntegrationTest {
   // 测试代码
}

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