当前位置：首页 > news >正文

【Kafka基础】topics命令行操作大全：进阶命令解析（2）

news 来源：原创 2025/6/22 23:46:45

1 查看主题的分区副本分配情况

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
    --bootstrap-server 192.168.10.33:9092 \
    --topics-with-overrides

参数说明：

--topics-with-overrides：显示所有配置被覆盖的主题

# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topics-with-overrides
Topic: testconfigtopic  PartitionCount: 4       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=false
Topic: __consumer_offsets       PartitionCount: 50      ReplicationFactor: 3    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=compact,segment.bytes=104857600,max.message.bytes=10485760,unclean.leader.election.enable=false
Topic: test_topic       PartitionCount: 3       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=false
Topic: testtopic1       PartitionCount: 3       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=false
[root@node6 bin]#

2 查看未同步的副本

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
    --bootstrap-server 192.168.10.33:9092 \
    --under-replicated-partitions

参数说明：

--under-replicated-partitions：显示所有未完成同步的分区

3 查看没有leader的分区

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
    --bootstrap-server 192.168.10.33:9092 \
    --unavailable-partitions

参数说明：

--unavailable-partitions：显示所有没有leader的分区

4 批量查看多个主题

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
    --bootstrap-server 192.168.10.33:9092 \
    --topic "testtopic1,testconfigtopic"

参数说明：

--topic：可以指定多个主题，用逗号分隔

# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic "testtopic1,testconfigtopic"
Topic: testconfigtopic  PartitionCount: 4       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=false
        Topic: testconfigtopic  Partition: 0    Leader: 1       Replicas: 1,2   Isr: 1,2
        Topic: testconfigtopic  Partition: 1    Leader: 2       Replicas: 2,3   Isr: 2,3
        Topic: testconfigtopic  Partition: 2    Leader: 3       Replicas: 3,1   Isr: 3,1
        Topic: testconfigtopic  Partition: 3    Leader: 1       Replicas: 1,3   Isr: 1,3
Topic: testtopic1       PartitionCount: 3       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=false
        Topic: testtopic1       Partition: 0    Leader: 1       Replicas: 1,2   Isr: 1,2
        Topic: testtopic1       Partition: 1    Leader: 2       Replicas: 2,3   Isr: 2,3
        Topic: testtopic1       Partition: 2    Leader: 3       Replicas: 3,1   Isr: 3,1
[root@node6 bin]#

5 查看主题的详细指标

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \ --bootstrap-server 192.168.10.33:9092 \ --topic-list testtopic1

参数说明：

--topic-list：显示更详细的指标信息

[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-log-dirs.sh --describe \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic-list testtopic1
Querying brokers for log directories information
Received log directory information from brokers 1,2,3
{"version":1,"brokers":[{"broker":1,"logDirs":[{"logDir":"/export/home/kafka_zk/kafka_2.13-2.7.1/logs","error":null,"partitions":[{"partition":"testtopic1-2","size":0,"offsetLag":0,"isFuture":false},{"partition":"testtopic1-0","size":0,"offsetLag":0,"isFuture":false}]}]},{"broker":2,"logDirs":[{"logDir":"/export/home/kafka_zk/kafka_2.13-2.7.1/logs","error":null,"partitions":[{"partition":"testtopic1-0","size":0,"offsetLag":0,"isFuture":false},{"partition":"testtopic1-1","size":0,"offsetLag":0,"isFuture":false}]}]},{"broker":3,"logDirs":[{"logDir":"/export/home/kafka_zk/kafka_2.13-2.7.1/logs","error":null,"partitions":[{"partition":"testtopic1-2","size":0,"offsetLag":0,"isFuture":false},{"partition":"testtopic1-1","size":0,"offsetLag":0,"isFuture":false}]}]}]}
[root@node6 bin]#