【Kafka中文社区】kafka原理：zookeeper中的存储结构讲解

 来源：Kafka知识星球  https://z.didi.cn/5gSF9

在这里插入图片描述

/cluster

/cluster/id 持久数据节点

集群ID 当第一台Broker启动的时候, 发现/cluster/id不存在,那么它就会把自己的cluster.id配置写入zk; 标记当前zk是属于集群哪个集群; 后面其他的Broker启动的时候会去获取该数据, 如果发现数据跟自己的配置不一致; 则抛出异常,加入的不是同一个集群; 数据示例：{"version":"1","id":"0"}

/controller_epoch 持久数据节点

Controller选举次数;

/Controller 临时数据节点

当前Controller角色的BrokerId,数据示例: {"version":1,"brokerid":0,"timestamp":"1624415590383"} 删除该节点立马触发重新选举

/log_dir_event_notification

【Kafka中文社区】kafka原理：zookeeper中的存储结构讲解最先出现在Python成神之路。