【问题标题】:Kafka List all partition with no leaderKafka列出没有领导者的所有分区
【发布时间】:2018-11-23 04:29:32
【问题描述】:

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

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

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

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

【问题讨论】:

    标签: apache-kafka apache-zookeeper


    【解决方案1】:

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

    例如:

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

    【讨论】:

    • 啊,谢谢你的回答。我在 topic.sh 中看到了这些选项,但不知道我可以完成我的工作,再次感谢您指出这一点。
    • 我尝试了上述方法,但它列出了没有领导者和有领导者的所有内容
    • 你的 Kafka 版本是什么?我们在 2.0.0 上运行,上面的命令对我们正常工作,即当我们没有 --unavailable-partitions 时,它会列出集群上的每个分区,当我们有它时它什么也不输出(因为我们所有的分区都是健康的)。
    • kafka 版本为 1.1
    猜你喜欢
    • 2021-11-08
    • 1970-01-01
    • 1970-01-01
    • 2016-07-01
    • 2021-10-12
    • 2020-07-05
    • 2020-10-18
    • 2020-11-11
    • 2020-03-30
    相关资源
    最近更新 更多