1 个回答
kafka rebalance 过程包含JoinGroup 请求和 SyncGroup 请求两类请求,它们分别用于加入消费者组和同步消费者组的分区分配。
1、JoinGroup 请求
1、JoinGroup 请求
当组内成员加入group时,它会向协调者发送一个JoinGroup请求。请求中会将自己要订阅的Topic 上报,这样Coordinator就可以收集到所有成员的订阅信息。收集完订阅信息之后,通常情况下,第一个发送JoinGroup 请求的成员将会自动成为Leader。
2、SyncGroup 请求当 Coordinator 收到所有组内成员的加入组请求后,会选出一个consumer Leader,然后让consumer Leader 通过策略进行分配,分配完后会将分配方案放入SyncGroup请求中发送回Coordinator, Coordinator根据分配方案发送给每个消费者。
当所有成员都成功接收到分配方案后,消费者组进入到 Stable 状态, 开始正常消费。发布于:3个月前 (01-24) IP属地:四川省
我来回答
您需要 登录 后回答此问题!