Kafka 列出所有没有领导者的分区

Question

在我的kafka集群中有超过2k个主题，每个主题有5个分区。我只想列出没有领导者的分区。

我可以使用以下语法检查每个主题：

kafka-topics.sh --describe --topic <topic_name> --zookeeper <zookeeper_ip>:port

但问题是有2k+个主题，无法手动完成。我还可以编写一个脚本来遍历每个主题并获得没有领导者的分区。但是我对一些获取信息的有效方法很感兴趣。

Answer 1

使用 kafka-topics.sh 您可以指定 --unavailable-partitions 标志以仅列出当前没有领导者因此不能被消费者或生产者使用的分区。

例如：

kafka-topics.sh --describe --unavailable-partitions --zookeeper <zookeeper_ip>:port