要查看Kafka的broken状态,您可以使用Kafka自带的命令行工具。请按照以下步骤操作:
kafka-topics.sh --zookeeper <zk-hostname>:<zk-port> --describe
将<zk-hostname>
和<zk-port>
替换为您的Zookeeper主机名和端口。例如:
kafka-topics.sh --zookeeper localhost:2181 --describe
Broken
状态的分区。它们将显示为Under-replicated
或Missing
的分区。例如:Topic: my_topic Partition: 0 Leader: 1 Replicas: 1 Isr: 1
Topic: my_topic Partition: 1 Leader: 2 Replicas: 1 Isr: 1
在这个例子中,分区1是Under-replicated的,表示它处于broken状态。
请注意,这些步骤适用于Kafka 0.9及更高版本。如果您使用的是早期版本的Kafka,可能需要使用不同的命令或工具来检查集群状态。