kafka集群管理
2020-08-19 23:51:50 13 举报kafka对象关系
作者其他创作
大纲/内容
元数据
producer
监听各种目录变化
1 尝试创建/controller/n 目录，n代表myid
broker(controller)
写入磁盘（跳表+稀疏索引）
/broker/topics/topica，topic b
leader p0
follower p0
/controller/n
往leader partition里面发送数据
元数据更新请求
获取集群的元素据信息（不一定是从主节点获取）
zookeeper集群
通过各种复杂的网络操作获取到数据
2 尝试创建/broker/ids/myid 目录myid
/broker/ids/0，1，2
p1
follower向leader同步数据
Broker（controller）监听zk文件目录变化（/broker/ids，/broker/topics），将元数据更新信息发送到其他broker
1 三个节点启动是时候，都会向zookeeper集群申请创建/controller/n节点（临时节点），谁获取到锁谁就是controller。2 producer在获取元数据的时候，从那个节点获取都一样，因为每个broker都维护了一份元数据
LEO HW变化
0 条评论
下一页
