kafka查看分区和副本数

Kafka是一款常用的分布式消息队列，在使用过程中，我们经常需要查看分区和副本数。本文将介绍如何使用Kafka命令行工具和Java代码示例来查看分区和副本数。

一、使用Kafka命令行工具查看分区和副本数

1. 查看Topic的分区数

使用Kafka命令行工具kafka-topics.sh，输入以下命令即可查看某个Topic的分区数：

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

其中，--zookeeper参数表示ZooKeeper连接地址，--describe参数表示查看Topic的详细信息，--topic参数表示需要查看的Topic名称。

2. 查看Topic的副本数

同样使用kafka-topics.sh命令行工具，输入以下命令即可查看某个Topic的副本数：

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test-topic | grep -e 'ReplicationFactor'

其中，grep -e 'ReplicationFactor'表示只显示包含字符串ReplicationFactor的行，也就是Topic的副本数所在的行。

二、使用Java代码示例查看分区和副本数

1. 查看Topic的分区数

首先需要添加kafka-clients依赖，Maven坐标如下：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.0.0</version>
</dependency>

然后编写Java代码，示例代码如下：

import java.util.Properties;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.DescribeTopicsResult;
import org.apache.kafka.clients.admin.TopicDescription;
import org.apache.kafka.common.TopicPartitionInfo;

public class KafkaAdmin {

    public static void main(String[] args) throws Exception {
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        AdminClient admin = AdminClient.create(props);

        DescribeTopicsResult result = admin.describeTopics(Arrays.asList("test-topic"));
        TopicDescription topicDescription = result.values().get("test-topic").get();
        List<TopicPartitionInfo> partitions = topicDescription.partitions();
        System.out.println("分区数：" + partitions.size());
    }
}

其中，AdminClient是Kafka提供的管理客户端，使用