Kafka: 使用选项自动创建主题

要使用选项自动创建 Kafka 主题，可以使用 KafkaAdminClient 类提供的 createTopics 方法。下面是一个示例代码：

import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.NewTopic;

import java.util.Properties;
import java.util.Collections;

public class KafkaTopicCreationExample {
    public static void main(String[] args) {
        // 配置 Kafka 服务器的地址
        Properties properties = new Properties();
        properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

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

        // 创建主题的配置选项
        NewTopic newTopic = new NewTopic("my-topic", 3, (short) 1);

        // 使用选项自动创建主题
        adminClient.createTopics(Collections.singleton(newTopic));

        // 关闭 KafkaAdminClient
        adminClient.close();
    }
}

上述代码创建了一个 KafkaAdminClient，并使用 NewTopic 对象指定了要创建的主题名称、分区数和副本因子。然后使用 createTopics 方法将主题创建到 Kafka 服务器上。

注意：在创建主题之前，需要确保 Kafka 服务器正在运行，并且提供正确的 bootstrap.servers 配置属性。