当前位置:   article > 正文

Kafka GroupCoordinator机制(十):GroupCoordinator之GroupState_groupcoordinator sent leavegrouprequest

groupcoordinator sent leavegrouprequest

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错误码标志。.

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小蓝xlanll/article/detail/125427
推荐阅读
相关标签
  

闽ICP备14008679号