Kafka组协调器
2021-11-06 16:51:50 7 举报关于Kafka协调器的介绍
作者其他创作
大纲/内容
输入正确
Leader消费者
普通消费者
注册页面
GroupCoordinator
进入软件
计算候选集中各个策略的选票数，票数最多的即为当前消费组的分配策略
消费组客户端
提示账号不存在
根据消费组的groupid的hashcode计算该消费者组的_consumer_offset的分区编号
每个消费者从候选集中找出第一个自己支持的策略，为这个策略投一票
普通消费者2
普通消费者1
否
JoinGroupResponse
JoinGroupRequest
账号错误
是
协议
发起请求到服务器寻找组协调器
消费者寻找组协调器的过程
组协调器Broker
leader消费者
提示密码错误请重新输入
参数验证
member_idgroup_protocols：支持的分区策略
发送SyncGroupRequest请求
密码错误
服务端
收集各个消费者支持的所有分配策略，组成候选集candidates
消费者申请加入组
输入账号密码登录
登录成功
找回密码
Kafka服务端
0 条评论
下一页
