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

Hac*_*lic 4 apache-kafka apache-zookeeper

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

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

kafka-topics.sh --describe --topic <topic_name> --zookeeper <zookeeper_ip>:port
Run Code Online (Sandbox Code Playgroud)

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

Mic*_*son 5

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

例如:

kafka-topics.sh --describe --unavailable-partitions --zookeeper <zookeeper_ip>:port
Run Code Online (Sandbox Code Playgroud)