要查看Kafka的broken状态,您可以使用Kafka自带的命令行工具。请按照以下步骤操作:
- 打开命令行终端。
- 输入以下命令以查看Kafka集群的状态:
kafka-topics.sh --zookeeper: --describe
将
和
替换为您的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,可能需要使用不同的命令或工具来检查集群状态。