Kafka中如何获取topic主题的列表？

在 Kafka 中，可以使用 Kafka 的命令行工具或者 Kafka 的客户端 API 来获取主题（topic）的列表。以下是两种常见的方法：

1. 使用 Kafka 命令行工具

使用 Kafka 提供的命令行工具 kafka-topics.sh（Unix/Linux）或 kafka-topics.bat（Windows）可以获取主题列表。以下是一个获取主题列表的示例命令：

kafka-topics.sh --list --zookeeper <Zookeeper 地址>

或者在最新版本的 Kafka 中，可以使用 --bootstrap-server 参数，如下：

kafka-topics.sh --list --bootstrap-server <Kafka Broker 地址>

替换 <Zookeeper 地址> 或 <Kafka Broker 地址> 为你实际的 ZooKeeper 地址或 Kafka Broker 地址。

2. 使用 Kafka 客户端 API

在 Java 等编程语言中，也可以使用 Kafka 的客户端 API 来获取主题列表。以下是一个简单的 Java 示例代码：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.ListTopicsOptions;
import org.apache.kafka.clients.admin.ListTopicsResult;

import java.util.Map;
import java.util.Set;

public class ListTopicsExample {
    public static void main(String[] args) {
        // 设置 Kafka 集群的 Bootstrap 服务器地址
        String bootstrapServers = "localhost:9092";

        // 设置 Kafka 客户端属性
        Map<String, Object> config = Map.of("bootstrap.servers", bootstrapServers);

        // 创建 AdminClient
        try (AdminClient adminClient = AdminClient.create(config)) {
            // 设置 ListTopicsOptions
            ListTopicsOptions options = new ListTopicsOptions().listInternal(true);

            // 获取主题列表
            ListTopicsResult topics = adminClient.listTopics(options);

            // 打印主题列表
            Set<String> topicNames = topics.names().get();
            for (String topic : topicNames) {
                System.out.println("Topic: " + topic);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个例子中，替换 localhost:9092 为你的 Kafka 集群的实际地址。

以上两种方法都可以用于获取 Kafka 集群中所有主题的列表信息。命令行工具更适用于快速检查和调试，而客户端 API 则更适用于集成到自己的应用程序中进行程序化操作。