查看kafka里topic

Kafka是一个高性能的分布式消息系统，它基于发布/订阅模型来处理流数据。在Kafka中，topic是一个逻辑上的概念，它用于组织和区分消息。本文将介绍如何在Kafka中查看topic，包括使用命令行工具和编程接口。

一、命令行工具

1. kafka-topics.sh

kafka-topics.sh是Kafka提供的一个用于管理topic的命令行工具，可以使用该工具查看当前Kafka集群中的所有topic，并获取每个topic的相关信息，包括partitions、replication factors、configs等。

查看当前Kafka集群中的所有topic：

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

查看指定topic的详情：

$ bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test

2. zookeeper-shell.sh

另外，可以使用zookeeper-shell.sh命令行工具查看Kafka中所有topic的详情。

$ bin/zookeeper-shell.sh localhost:2181 <<< "ls /brokers/topics"

二、编程接口

1. Java API

Kafka提供了Java API用于编程访问Kafka集群，通过Java API可以查看Kafka中的所有topic。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
try (AdminClient client = AdminClient.create(props)) {
    ListTopicsResult topicsResult = client.listTopics();
    Set<String> topics = topicsResult.names().get();
    System.out.println(topics);
}

2. Python API

对于Python开发者，可以使用kafka-python包查看Kafka中的所有topic。

from kafka.admin import KafkaAdminClient, ConfigResource, ConfigResourceType
admin_client = KafkaAdminClient(bootstrap_servers="localhost:9092")
all_topics = admin_client.list_topics()
print(all_topics)

以上是本文介绍的Kafka中查看topic的方法，通过命令行工具和编程接口，可以方便地获取Kafka集群中所有topic的信息，方便后续的数据处理和分析。