SpringBoot2+SpringKafka：ALLOW_AUTO_CREATE_TOPICS_CONFIG不生效问题

问题本质 #

你遇到的是Kafka客户端的预期行为：

• 消费者配置allow.auto.create.topics: false仅控制消费者订阅主题时是否触发自动创建，完全不影响生产者发送消息的逻辑。
• 当Broker端auto.create.topics.enable=true时，生产者发送消息到不存在的主题时，默认会自动触发主题创建，这是Kafka生产者客户端的原生默认行为。

生产者端禁用自动创建主题的方法 #

要在生产者层面阻止自动创建主题，需配置生产者的enable.auto.create.topics参数为false，有两种配置方式：

1. 通过application.yml配置

在生产者的配置节点中添加：

spring:
  kafka:
    producer:
      properties:
        enable.auto.create.topics: false

2. 通过代码配置

在生产者工厂的配置中显式设置：

@Bean
public ProducerFactory<String, Object> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
    configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
    // 禁用生产者自动创建主题
    configProps.put(ProducerConfig.ENABLE_AUTO_CREATE_TOPICS_CONFIG, false);
    return new DefaultKafkaProducerFactory<>(configProps);
}

验证效果 #

配置完成后，当生产者尝试发送消息到未预先创建的主题时，会抛出org.apache.kafka.common.errors.UnknownTopicOrPartitionException，而非自动创建主题，符合预期。

补充建议 #

如果需要确保主题存在再进行生产/消费，可：

• 在应用启动时通过TopicBuilder显式创建主题：

@Bean
public NewTopic myTopic() {
    return TopicBuilder.name("my-topic")
            .partitions(3)
            .replicas(1)
            .build();
}

• 测试环境中使用@EmbeddedKafka时，通过topics属性预先定义主题：

@EmbeddedKafka(topics = {"my-topic"})
class EmbeddedKafkaIntegrationTest {
    // 测试代码
}

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