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+主题,无法手动完成。我还可以编写一个脚本来循环每个主题并获取没有领导者的分区。但我对获取信息的有效方式感兴趣。
使用kafka-topics.sh您可以指定该--unavailable-partitions标志以仅列出当前没有领导者的分区,因此消费者或生产者无法使用。
例如:
kafka-topics.sh --describe --unavailable-partitions --zookeeper <zookeeper_ip>:port
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
3206 次 |
| 最近记录: |