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 条评论
回复 删除
下一页