Kafka GroupCoordinator机制(十六)：GroupCoordinator之LeaveGroupRequest分析

消费者离开消费者组是向GroupCoordinator发送LeaveGroupRequest。

  def handleLeaveGroup(groupId: String, consumerId: String, responseCallback: Short => Unit) {if (!isActive.get) {responseCallback(Errors.GROUP_COORDINATOR_NOT_AVAILABLE.code)} else if (!isCoordinatorForGroup(groupId)) {responseCallback(Errors.NOT_COORDINATOR_FOR_GROUP.code)} else if (isCoordinatorLoadingInProgress(groupId)) {responseCallback(Errors.GROUP_LOAD_IN_PROGRESS.code)} else {val group = groupManager.getGroup(groupId)if (group == null) {// if the group is marked as dead, it means some other thread has just removed the group// from the coordinator metadata; this is likely that the group has migrated to some other// coordinator OR the group is in a transient unstable phase. Let the consumer to retry// joining without specified consumer id,responseCallback(Errors.UNKNOWN_MEMBER_ID.code)} else {group synchronized {if (group.is(Dead)) {//如果遇到Group处于Dead、未知的memberID，就调用回调函数返回错误码responseCallback(Errors.UNKNOWN_MEMBER_ID.code)} else if (!group.has(consumerId)) {responseCallback(Errors.UNKNOWN_MEMBER_ID.code)} else {val member = group.get(consumerId)removeHeartbeatForLeavingMember(group, member)// 移除memberMetadata对象并完成状态转化onMemberFailure(group, member)responseCallback(Errors.NONE.code)}}}}}

  private def onMemberFailure(group: GroupMetadata, member: MemberMetadata) {trace("Member %s in group %s has failed".format(member.memberId, group.groupId))group.remove(member.memberId)group.currentState match {case Dead =>case Stable | AwaitingSync => maybePrepareRebalance(group)case PreparingRebalance => joinPurgatory.checkAndComplete(GroupKey(group.groupId))}}

Kafka GroupCoordinator机制(十六)：GroupCoordinator之LeaveGroupRequest分析相关推荐

python数据挖掘学习笔记】十六.逻辑回归LogisticRegression分析鸢尾花数据
但是很多时候数据是非线性的,所以这篇文章主要讲述逻辑回归及Sklearn机器学习包中的LogisticRegression算法 #2018-03-28 16:57:56 March Wednesday ...
python分析鸢尾花数据_python数据挖掘学习笔记】十六.逻辑回归LogisticRegression分析鸢尾花数据...
但是很多时候数据是非线性的,所以这篇文章主要讲述逻辑回归及Sklearn机器学习包中的LogisticRegression算法 #2018-03-28 16:57:56 March Wednesday ...
【python数据挖掘课程】十六.逻辑回归LogisticRegression分析鸢尾花数据
今天是教师节,容我先感叹下. 祝天下所有老师教师节快乐,这是自己的第二个教师节,这一年来,无限感慨,有给一个人的指导,有给十几个人讲毕设,有几十人的实验,有上百人的课堂,也有给上千人的Python网络 ...
斗地主AI算法——第十六章の样例分析
上一章,我们已经完成了测试模块的开发.至此我们已经可以进行整体测试了.本章主要内容就是对随机生成的对局情况进行简单的分析. 实际上整个开发过程绝大部分时间都是用在样例分析上,通过样例给出的返回操作分析 ...
[系统安全] 二十六.WannaCry勒索病毒分析 (2)MS17-010漏洞利用及蠕虫解析
您可能之前看到过我写的类似文章,为什么还要重复撰写呢?只是想更好地帮助初学者了解病毒逆向分析和系统安全,更加成体系且不破坏之前的系列.因此,我重新开设了这个专栏,准备系统整理和深入学习系统安全.逆向分 ...
[系统安全] 四十六.Powershell恶意代码检测系列 (1)Powershell基础入门及管道和变量的用法
您可能之前看到过我写的类似文章,为什么还要重复撰写呢?只是想更好地帮助初学者了解病毒逆向分析和系统安全,更加成体系且不破坏之前的系列.因此,我重新开设了这个专栏,准备系统整理和深入学习系统安全.逆向分 ...
QT开发（六十六）——登录对话框的验证机制
QT开发(六十六)--登录对话框的验证机制一.验证码机制为了避免被恶意程序***,程序通常要使用安全机制.验证码机制是提供产生随机验证码,由用户识别填写来判断用户有效性的安全机制. 验证码必须动态 ...
Senparc.Weixin.MP SDK 微信公众平台开发教程（十六）：AccessToken自动管理机制
在<Senparc.Weixin.MP SDK 微信公众平台开发教程(八):通用接口说明>中,我介绍了获取AccessToken(通用接口)的方法. 在实际的开发过程中,所有的高级接口都需 ...
6张图阐述Kafka心跳机制（时间轮算法的具体运用）
Broker端与客户端的心跳在Kafka中非常的重要,因为一旦在一个心跳过期周期内(默认10s),Broker端的消费组组协调器(GroupCoordinator)会把消费者从消费组中移除,从而触发重 ...

Kafka GroupCoordinator机制(十六)：GroupCoordinator之LeaveGroupRequest分析

Kafka GroupCoordinator机制(十六)：GroupCoordinator之LeaveGroupRequest分析相关推荐

最新文章

热门文章