Rebalance进入Join Group流程
2018-02-03 22:19:56 0 举报Rebalance第二阶段JoinGroup
作者其他创作
大纲/内容
ConsumerNetworkClient #poll()
AbstractCoordinator#ensureCoordinatorReady()
SubscriptionState#partitionsAutoAssigned()
AbstractCoordinator#initiateJoinGroup()
AbstractCoordinator#sendJoinGroupRequest()
SubscriptionState#hasPatternSubscription()
false
AbstractCoordinator#onJoinPrepare()
ConsumerCoordinator#needRejoin()
needsJoinPrepare
AbstractCoordinator#joinGroupIfNeeded()
AbstractCoordinator#startHeartbeatThreadIfNeeded()
AbstractCoordinator#needRejoin()||AbstractCoordinator#rejoinIncomplete()
joinFuture == null
结束
开始
AbstractCoordinator#ensureActiveGroup()
ConsumerNetworkClient#ensureFreshMetadata()
ConsumerNetworkClient #send()
职业：暂无
0 条评论
下一页
