我有一个由 3 个节点组成的 Kafka 集群,每个节点有 1 个 ZK 和 1 个 Broker。
Kafka version 0.10.1.1.
每个主题都有replication-factor=3
和min.insync.replicas=2
。此后我们通过发布检查--describe
主题是否已使用正确的replication-factor
和成功创建ISR
。
一段时间后,我可以看到一些主题将其 ISR 缩小为单一领导者。
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic topic1
Topic:topic1 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: topic1 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic topic2
Topic:topic2 PartitionCount:1 ReplicationFactor:1 Configs:
Topic: topic2 Partition: 0 Leader: 1 Replicas: 1 Isr: 1
当我连接到zk Shell
. 我可以看到所有节点都已启动并且controller
在broker:2
/opt/kafka/bin/zookeeper-shell.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181
ls /brokers/ids
[0,1,2]
get /controller
{"version":1,"brokerid":2,"timestamp":"1531740996571"}
即使我尝试重新启动代理(仅代理或与动物园管理员一起),主题也不会扩展。
任何建议都非常感谢!