kafka触发再平衡的过程是什么?

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