赞
踩
GroupState接口用于表示消费者组的状态,四个子类分别代表四个不同的状态:
PreparingRebalance:消费者组正在进行rebalance操作
当消费者处于这个状态时,GroupCoordinator可以正常处理offsetFetchRequest、leaveGroupRequest、offsetCommitRequest,但对于收到heartbeatrequest和SyncGropRequest,则会在其响应中携带REBALANCE_IN_PROGRESS错误进行标识。当收到joinGroupRequest时,GroupCoordinator会创建对应的DelayJoin,等待条件满足后进行响应。
PreparingRebalance --> AwaitngSync
当有delayedJoin超时或者消费者组之前的member已经重新申请加入时进行的切换
PreparingRebalance --> Dead
所有member离开消费者组
AwaitngSync:消费者组正在等待group leader将分区的分配结果发送到GroupCoordinator
当消费者组处于这个状态时,表示正在等待group leader将分区的分配结果。当收到offsetCommitRequest和HeartbeatRequest时,则会在其响应中携带REBALANCE_IN_PROGRESS错误进行标识。对于来自Group Follower的SyncGroupRequest,则直接抛弃,直到收到leader的SyncGroupRequest时一起响应。
AwaitngSync --> Stable
收到leader的SyncGroupRequest
AwaitngSync --> PreparingRebalance
三种情况触发:1. 有消费者加入或者退出消费者组。2. 新的member请求加入消费者组。3. 消费者组中有member心跳超时
Stable:消费者处于正常状态
此状态可以处理所有请求
Stable --> PreparingRebalance
1. 消费者组中有member心跳超时。2. 有消费者主动退出消费者组。 3. 新的member请求加入消费者组 4. 当前group leader发送JoinGroupRequest
Dead:已经没有member存在。
除了OffsetCommitRequest,其他请求的响应会携带UNKNOWN_MEMBER_ID错误码标志。.
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。