doris数据库对接kafka入库数据怎么自动创建kafka 的topic

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

创建一个Kafka的AdminClient对象：

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

定义一个方法来创建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();
}

在数据入库之前，调用上述方法来创建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的地址