kafka查看topic节点数

Apache Kafka 是一个开源流处理平台，广泛用于数据流处理、消息队列以及实时数据传输等场景。Kafka 通过分布式消息日志系统实现了高吞吐量、低延迟、持久化以及分布式的特性，可以很方便地实现实时流数据的处理。在 Kafka 中，Topic 是消息的分类标准，它是消息的生产者和消费者之间交流消息的桥梁。而在 Kafka 中，每个 Topic 可以有多个 Partition，每个 Partition 存储部分消息数据，以此来提高处理性能。

有时候，我们需要查看一个 Topic 中有多少个 Partition，以方便进行后续操作，比如增加或者减少 Partition。本文将介绍如何通过 Kafka 命令行工具和 Java 代码来查看 Topic 的节点数。

通过 Kafka 工具查看 Topic 节点数

Kafka 提供了一个命令行工具 kafka-topics.sh 用来对 Topic 进行管理。我们可以使用该工具来查看具体某个 Topic 的 Partition 节点数。

执行以下命令：

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

其中，my-topic 为待查看的 Topic 名称。

执行后，输出结果如下：

Topic:my-topic  PartitionCount:4  ReplicationFactor:1 Configs:
        Topic: my-topic Partition: 0    Leader: 1   Replicas: 1 Isr: 1
        Topic: my-topic Partition: 1    Leader: 2   Replicas: 2 Isr: 2
        Topic: my-topic Partition: 2    Leader: 1   Replicas: 1 Isr: 1
        Topic: my-topic Partition: 3    Leader: 2   Replicas: 2 Isr: 2

其中，PartitionCount 即为节点数，本例中 my-topic 有 4 个 Partition，分别为 0、1、2、3。

通过 Java 代码查看 Topic 节点数

除了使用 Kafka 命令行工具，我们也可以通过 Java 代码来查看 Topic 的节点数。下面是一个 Java 代码示例用来获取 Topic 的节点数：

import java.util.Properties;

import kafka.admin.AdminClient;
import kafka.admin.AdminClientConfig;
import kafka.admin.Topic