Kafka生产者单元测试报错：无法自动装配EmbeddedKafkaBroker Bean

可能的原因及解决办法 #

1. 缺失spring-kafka-test依赖 #

EmbeddedKafkaBroker属于spring-kafka-test模块，必须确保测试依赖中包含该模块：

• Gradle项目添加：

testImplementation 'org.springframework.kafka:spring-kafka-test'

• Maven项目添加：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka-test</artifactId>
    <scope>test</scope>
</dependency>

2. 测试类访问修饰符问题 #

你使用了Kotlin的internal class修饰测试类，可能导致Spring无法扫描并创建相关Bean，改为普通class即可：

class KafkaProducerServiceTest {
    // 原有代码保持不变
}

3. @EmbeddedKafka配置冲突 #

尝试简化@EmbeddedKafka的配置，移除可能引发冲突的bootstrapServersProperty，让框架自动处理地址配置：

@EmbeddedKafka(
   partitions = 1,
   topics = arrayOf("someTopic")
)

4. Spring自动配置未触发 #

检查@SpringBootTest是否排除了Kafka相关自动配置类（如KafkaAutoConfiguration），若有则移除排除规则；同时确认test环境的配置文件没有覆盖Kafka自动配置，导致EmbeddedKafkaBroker Bean未被创建。

5. 调整注入方式（备选） #

如果以上方法无效，可尝试放宽注入要求，先验证Bean是否存在：

@Autowired(required = false)
lateinit var embeddedKafkaBroker: EmbeddedKafkaBroker

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