Spring Kafka 的 allow.auto.create.topics=false 仅影响消费者端的元数据请求行为，无法阻止生产者触发 Topic 自动创建；真正生效的控制点是 Kafka Broker 的 auto.create.topics.enable=false，或通过 AdminClient 主动预创建 Topic。
spring kafka 的 `allow.auto.create.topics=false` 仅影响消费者端的元数据请求行为，无法阻止生产者触发 topic 自动创建；真正生效的控制点是 kafka broker 的 `auto.create.topics.enable=false`，或通过 adminclient 主动预创建 topic。
在 Spring Boot + Spring Kafka 集成测试中，开发者常误以为设置 ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG = "false" 就能完全禁止 Topic 自动创建。但事实是：该配置仅作用于消费者发起的 metadata 请求（如 listTopics() 或首次订阅时的元数据拉取），而对生产者发送消息时触发的自动建 Topic 行为完全无效。
Kafka 协议层面的设计决定了：只要 Broker 配置 auto.create.topics.enable=true（默认值），任何客户端（包括 Producer）向一个不存在的 Topic 发送第一条消息时，Broker 就会自动创建该 Topic。这是 Kafka 服务端行为，与客户端配置无关。因此，即使你在 ConsumerFactory 中明确设置了 "allow.auto.create.topics": "false"，只要 Producer 调用了 kafkaTemplate.send(topic, data)，且该 Topic 尚未存在，Broker 仍会创建它。
✅ 正确的解决方案
1. 优先关闭 Broker 级自动创建（推荐）
在 @EmbeddedKafka 注解中显式禁用：
@EmbeddedKafka(
partitions = 1,
brokerProperties = {
"listeners=PLAINTEXT://localhost:9092",
"auto.create.topics.enable=false" // ? 关键：服务端禁用
}
)此时，若 Producer 向未存在的 Topic 发送消息，将抛出 UnknownTopicOrPartitionException，测试立即失败，便于早期发现问题。
⚠️ 注意：若同时使用 @EmbeddedKafka 和 spring.kafka.bootstrap-servers，需确保两者指向同一 Broker 实例，避免配置被覆盖。
2. 测试前主动创建 Topic（更可控）
借助 KafkaAdmin 在测试启动时预创建 Topic，彻底规避自动创建：
@Bean
public NewTopic testTopic() {
return TopicBuilder.name("${test.topic}")
.partitions(1)
.replicas(1)
.build();
}Spring Boot 2.3+ 会自动检测 NewTopic Bean 并交由 KafkaAdmin 初始化（需确保 KafkaAdmin 已声明且 autoCreate 为 true，默认启用）。
3. 生产环境最佳实践
- 基础设施层：在 Kafka 集群配置中永久关闭 auto.create.topics.enable=false；
- CI/CD 层：通过 kafka-topics.sh 或 AdminClient 脚本统一管理 Topic 生命周期；
- 应用层：移除所有 allow.auto.create.topics=false 的 Consumer 配置（它不解决根本问题，且易造成误导）。
❌ 常见误区澄清
- ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG 不是“开关”，而是“提示”：它仅告诉消费者——当收到 UNKNOWN_TOPIC_OR_PARTITION 错误时，不要尝试重试元数据请求来等待 Topic 创建，而是直接报错。它无法阻止 Broker 创建 Topic。
- @KafkaListener 的 topics = "${test.topic}" 会在容器启动时触发一次 metadata 请求，若此时 Topic 不存在且 Broker 允许自动创建，Topic 就会被创建——这与 Consumer 配置无关，而是 Broker 行为。
- KafkaTemplate.send() 是触发自动建 Topic 的主要入口，而非 KafkaListener。
总结
| 控制点 | 是否有效 | 说明 |
|---|---|---|
| ConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG=false | ❌ 无效 | 仅影响消费者错误处理逻辑，不阻止 Broker 创建 |
| ProducerConfig 中设置相同属性 | ❌ 无效 | Producer 不识别该参数 |
| Broker auto.create.topics.enable=false | ✅ 根本解法 | 所有客户端均无法触发自动创建 |
| KafkaAdmin + NewTopic Bean | ✅ 主动防御 | 确保 Topic 存在，且可精确控制分区/副本 |
真正的 Topic 治理应前置到基础设施和部署流程中，而非依赖客户端“假装禁用”。在测试中主动创建 Topic，既能验证 Topic 配置正确性，又能避免环境差异导致的不可预期行为。
