查看kafka已创建的主题

在Kafka中，主题（Topic）是消息的基本管理单位。为了避免多余的操作，我们需要在使用Kafka的过程中管理主题。本文将介绍如何查看Kafka已创建的主题，并提供代码示例。

一、Kafka中主题的创建

在Kafka中创建主题十分简单。我们可以使用kafka-topics.sh脚本，在终端中输入以下命令：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

其中，--create表示创建主题，--zookeeper指定了Kafka所使用的Zookeeper地址，--replication-factor和--partitions分别指定了副本数量和分区数量，--topic指定了主题名称。

二、查看Kafka已创建的主题

在Kafka中，我们可以使用kafka-topics.sh脚本查看Kafka已创建的主题。在终端中输入以下命令：

bin/kafka-topics.sh --list --zookeeper localhost:2181

这个命令会在终端中列出所有已创建的主题。

但是，kafka-topics.sh脚本并不是Kafka的Java API。如果我们想在Java项目中查看Kafka已创建的主题，我们应该使用Kafka的Java API。我们可以使用org.apache.kafka.clients.admin.AdminClient来获取已创建的主题。代码示例如下：

Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, 30000);
try (AdminClient client = AdminClient.create(props)) {
    ListTopicsOptions options = new ListTopicsOptions();
    options.listInternal(false);
    Collection<TopicListing> listings = client.listTopics(options).listings().get();
    System.out.println("已创建的主题:");
    for (TopicListing listing : listings) {
        System.out.println(listing.name());
    }
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

在代码中，我们首先创建了AdminClient，然后使用ListTopicsOptions过滤掉内部主题，使用listTopics方法获取已创建的主题，最后遍历主题列表并输出主题名。

三、总结

在Kafka中，我们可以使用kafka-topics.sh脚本在终端中查看Kafka已创建的主题。我们也可以使用Kafka的Java