Kafka Producer(Java) API是否提供Topic自动创建相关配置？

结论先行：Java版Kafka Producer原生API没有提供和KIP-158规范下Kafka Connect对等的、发送消息时自动按自定义配置创建新Topic的内置能力。

• 原生Producer的默认逻辑：如果待发送消息的目标Topic不存在，Producer不会主动发起Topic创建请求，只会依赖Broker端的自动创建开关（即auto.create.topics.enable参数）触发建Topic流程。这种方式创建的Topic完全使用Broker集群的全局默认配置，无法在Producer侧为单个新Topic指定分区数、副本数、留存策略、压缩规则等专属参数，和KIP-158支持的能力不对等。
• 等效实现方案：如果需要实现类似效果，可以在业务代码中集成Kafka AdminClient，在Producer发送消息前显式调用创建Topic的接口，传入自定义的Topic配置，待Topic创建完成后再启动Producer发送流程，完全不需要依赖Broker的自动创建能力。

参考实现代码：

// 加载集群连接配置
Properties commonProps = new Properties();
commonProps.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "集群Broker地址列表");

// 先通过AdminClient按自定义配置建Topic
try (AdminClient adminClient = AdminClient.create(commonProps)) {
    NewTopic targetTopic = new NewTopic("业务目标Topic名", 8, (short) 2)
            .configs(Map.of(
                    "retention.ms", "604800000", // 数据留存7天
                    "compression.type", "zstd",
                    "min.insync.replicas", "1"
            ));
    // 执行创建，Topic已存在时直接跳过即可
    try {
        adminClient.createTopics(List.of(targetTopic)).all().get();
    } catch (ExecutionException e) {
        if (!(e.getCause() instanceof TopicExistsException)) {
            throw new RuntimeException("Topic创建异常", e);
        }
    }
}

// Topic创建校验完成后，初始化KafkaProducer正常发消息即可
KafkaProducer<String, String> producer = new KafkaProducer<>(commonProps);

生产环境提示：不建议开启Broker端的自动Topic创建功能，自动生成的Topic默认配置往往不符合业务的容量、容灾要求，容易出现分区热点、数据可靠性不足等问题，推荐通过AdminClient提前按业务规范显式创建Topic。

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