java代码创建kafka topic

可以使用 Kafka 的 Java API 来创建一个 Kafka topic。下面是一个简单的示例代码：

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

public class CreateTopicExample {

    public static void main(String[] args) {
        // 创建 Kafka 管理员客户端
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        AdminClient adminClient = AdminClient.create(props);

        // 创建一个新的 topic
        String topicName = "my-topic";
        int numPartitions = 1;
        short replicationFactor = 1;
        NewTopic newTopic = new NewTopic(topicName, numPartitions, replicationFactor);
        adminClient.createTopics(Collections.singleton(newTopic));

        // 关闭管理员客户端
        adminClient.close();
    }
}

上述代码会创建一个名为 `my-topic` 的 topic，分区数为 1，副本因子为 1。你可以根据需要修改相应参数。