Spring Kafka v1.1.6无法禁用主题自动创建问题求助

核心问题：配置项放错了位置 #

你添加的allow.auto.create.topics是Kafka Broker端的配置，不是生产者客户端配置，所以放到生产者工厂里完全不会生效。正确的Broker端禁用自动创建主题的配置是：

• 在Broker的server.properties中设置：auto.create.topics.enable=false
• 重启Broker后，当生产者发送消息到不存在的主题时，会直接抛出UnknownTopicOrPartitionException，不会自动创建主题。

如果无法修改Broker配置（客户端层面替代方案） #

如果没有权限修改Broker配置，可以在发送消息前，先通过AdminClient检查主题是否存在，不存在则抛出异常：

1. 添加AdminClient Bean #

@Value("${kpi.kafka.bootstrap-servers}")
private String bootstrapServer;

@Bean
public AdminClient adminClient() {
    Map<String, Object> config = new HashMap<>();
    config.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer);
    return AdminClient.create(config);
}

2. 发送前检查主题 #

修改你的发送方法，先校验主题存在性：

@Autowired
private AdminClient adminClient;
@Autowired
private KafkaTemplate<String, CmsMonitoringMetrics> kafkaTemplateJson;

public void sendMessage(String topicName, CmsMonitoringMetrics data) throws ExecutionException, InterruptedException {
    // 检查主题是否存在
    ListTopicsResult topicsResult = adminClient.listTopics();
    Set<String> existingTopics = topicsResult.names().get();
    if (!existingTopics.contains(topicName)) {
        throw new IllegalArgumentException("主题 " + topicName + " 不存在，禁止发送");
    }
    // 原发送逻辑
    Message<CmsMonitoringMetrics> message = MessageBuilder.withPayload(data)
            .setHeader(KafkaHeaders.TOPIC, topicName)
            .build();
    SendResult<String, CmsMonitoringMetrics> result = kafkaTemplateJson.send(message).get();
}

注意事项 #

• Spring Kafka 1.1.6对应Kafka客户端0.11.x版本，AdminClient的API与新版略有差异，上述代码适配该版本。
• 客户端检查是最终一致性的，检查与发送之间可能存在主题变更，但能满足绝大多数场景需求。

为什么之前的配置无效？ #

• spring.kafka.topic.properties.auto.create=false：配置项名称错误，正确的Broker端配置为auto.create.topics.enable，且该配置只能在Broker配置文件中设置，无法通过客户端传递。
• allow.auto.create.topics：该配置是新版Kafka客户端新增的控制项，在你使用的0.11.x/Spring Kafka 1.1.6版本中不存在，客户端无法干预Broker的自动创建主题行为，完全由Broker的auto.create.topics.enable参数决定。

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