Spring Embedded Kafka+JUnit5测试报错：无法解析Bootstrap Servers地址

你遇到的这个报错，核心问题是同时混用了@EmbeddedKafka注解和手动实例化EmbeddedKafkaBroker的方式，这直接打乱了Spring Boot对嵌入式Kafka的自动配置逻辑，导致配置文件里的{spring.embedded.kafka.brokers}占位符无法解析到实际的Broker地址。

下面是具体的修复步骤：

1. 移除手动实例化的EmbeddedKafkaBroker #

@EmbeddedKafka注解本身就会帮你自动创建并管理一个EmbeddedKafkaBroker实例，完全不需要手动new。你可以通过依赖注入获取Spring管理的实例：

@SpringBootTest
@EmbeddedKafka(topics = {"your-target-topic"}) // 直接在这里声明测试需要的Topic
public class MyTest {

    // 注入Spring自动配置好的EmbeddedKafkaBroker
    @Autowired
    private EmbeddedKafkaBroker embeddedKafka;

    @Test
    public void myTestCase() {
        // 若需要手动获取Broker地址，可调用该方法
        String bootstrapServers = embeddedKafka.getBrokersAsString();
        // 后续生产者/消费者可直接使用这个地址
    }
}

2. 确保配置文件的占位符正确生效 #

在你的测试环境配置文件（比如application-test.yml）中，保持以下配置即可：

spring:
  kafka:
    bootstrap-servers: ${spring.embedded.kafka.brokers}

当你使用@EmbeddedKafka注解时，Spring会自动将启动的嵌入式Kafka实际地址（动态分配的端口）注入到spring.embedded.kafka.brokers环境变量中，配置文件的占位符就能正确解析。而手动实例化Broker时，Spring的自动配置流程不会触发这个变量的注入，导致占位符失效，最终出现bootstrap urls为空的错误。

额外注意事项 #

• 如果你不需要手动操作EmbeddedKafkaBroker，甚至可以不用注入它——@EmbeddedKafka会自动让你的KafkaTemplate、消费者工厂等组件默认使用嵌入式Kafka的地址。
• 确保测试依赖中正确引入了spring-kafka-test（这是嵌入式Kafka的核心依赖）：

<!-- Maven示例 -->
<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka-test</artifactId>
    <scope>test</scope>
</dependency>

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