Doris 数据库自动创建 Kafka topic 入库数据

要自动创建 Kafka 的 topic，可以使用 Kafka 的 AdminClient 来完成。以下是一种可能的实现方式：

1. 创建一个 Kafka 的 AdminClient 对象：

Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, 'kafka-bootstrap-server:9092');
AdminClient adminClient = AdminClient.create(props);

2. 定义一个方法来创建 topic：

public void createTopic(String topicName, int partitions, short replicationFactor) throws ExecutionException, InterruptedException {
    NewTopic newTopic = new NewTopic(topicName, partitions, replicationFactor);
    adminClient.createTopics(Collections.singletonList(newTopic)).all().get();
}

3. 在数据入库之前，调用上述方法来创建 topic：

String topicName = 'your-topic-name';
int partitions = 3;
short replicationFactor = 1;
createTopic(topicName, partitions, replicationFactor);

这样就可以在数据入库之前自动创建 Kafka 的 topic 了。需要注意的是，Kafka 的 AdminClient 需要与 Kafka 集群的 bootstrap server 建立连接，所以需要正确配置 bootstrap server 的地址。