Kafka无法在应用程序启动时配置主题，但稍后可以通信

kafka-topics.sh --create --topic mytopic --partitions 3 --replication-factor 1 --bootstrap-server localhost:9092

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

import java.util.Properties;

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

        // 创建AdminClient对象
        try (AdminClient adminClient = AdminClient.create(props)) {
            // 创建一个名为"mytopic"的主题，有3个分区，副本因子为1
            NewTopic newTopic = new NewTopic("mytopic", 3, (short) 1);
            adminClient.createTopics(Collections.singleton(newTopic));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}