java代码实现kafka自动创建topic

您可以使用KafkaAdminClient API来通过Java代码实现自动创建Kafka topic。

以下是一个简单的Java代码示例：

import java.util.Properties;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.NewTopic;

public class KafkaTopicCreator {
    public static void main(String[] args) {
        // 设置Kafka集群的地址
        Properties properties = new Properties();
        properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        // 创建AdminClient实例
        AdminClient adminClient = AdminClient.create(properties);

        // 创建一个名为"test"的Topic，其中包括2个分区和2个副本
        NewTopic newTopic = new NewTopic("test", 2, (short) 2);

        // 使用AdminClient创建Topic
        adminClient.createTopics(Collections.singleton(newTopic));

        // 关闭AdminClient实例
        adminClient.close();
    }
}

在上述代码中，我们使用了KafkaAdminClient API来创建了一个名为“test”的Topic，其中包括2个分区和2个副本。您可以根据需要修改代码中的参数和属性，以满足您的需求。