Rebalance进入Synchronizing Group State流程
2018-02-05 02:49:36 0 举报Rebalance进入Synchronizing Group State流程
作者其他创作
大纲/内容
AbstractCoordinator#onJoinLeader()
ConsumerCoordinator#performAssignment()
开始
RequestFuture#complete()
JoinGroupResponseHandler#handle()
error == Errors.NONE
JoinGroupResponse#isLeader()
ConsumerNetworkClient#send()
结束
Metadata#setTopics()
AbstractCoordinator#onJoinFollower()
state != REBALANCING
RequestFuture#raise()
isLeader = true
SyncGroupResponseHandler#handle()
AbstractCoordinator#sendSyncGroupRequest()
PartitionAssignor#assign()
分配结果序列化
ConsumerNetworkClient #ensureFreshMetadata()
SubscriptionState#groupSubscribe()
AbstractCoordinator#requestRejoin()
职业：暂无
0 条评论
下一页
