副本选举流程图
2021-12-11 11:52:46 0 举报
副本选举流程图
作者其他创作
大纲/内容
sh bin/kafka-leader-election.sh --bootstrap-server 127.0.0.1:9092 --path-to-json-file config/leaderElection/election.json --election-type preferred
更新controllerContext
给集群中每个broker发送updateMetadata请求
结束
LeaderElectionCommand
发送请求
校验分区是否有效
分区状态机处理流程
将选举结果写入zk
给每个还存活的副本发送leaderAndIsr请求
校验是否在删除队列中
根据入参设置策略
kafka cluster
开始
发送ElectLeadersRequest
执行副本选举脚本
处理返回参数
调用KafkaAdminClient#electLeaders
调用分区状态机修改状态
返回结果
broker 1:127.0.0.1:9093
校验参数
根据策略选出leader
broker 1:127.0.0.1:9092
校验重选举的条件是否成立
发送MetadataRequestData获取kafkaController
0 条评论
回复 删除
下一页
