Kafka消费者主流程图
2018-01-21 22:28:47 0 举报Kafka消费者流程图
作者其他创作
大纲/内容
SubscriptionState#hasNoSubscriptionOrUserAssignment()
ConsumerCoordinator#coordinatorUnknown()
interceptors == null
ConsumerCoordinator#ensureCoordinatorReady()
ConsumerCoordinator#invokeCompletedOffsetCommitCallbacks()
ConsumerCoordinator#poll()
Fetcher#fetchedRecords()
ConsumerInterceptors#onConsume()
没有数据
IllegalStateException
false
Fetcher#sendFetches()
Metadata#updateRequested()
KafkaConsumer#poll()
KafkaConsumer#updateFetchPositions()
SubscriptionState#hpartitionsAutoAssigned()
KafkaConsumer#pollOnce()
获取数据
ConsumerNetworkClient#ensureFreshMetadata()
ConsumerNetworkClient#poll()
ConsumerNetworkClient#pollNoWakeup()
SubscriptionState#hasAllFetchPositions()
SubscriptionState#hasPatternSubscription()
ConsumerCoordinator#needRejoin()
ConsumerCoordinator#pollHeartbeat()
ConsumerCoordinator#maybeAutoCommitOffsetsAsync()
end
ConsumerCoordinator#ensureActiveGroup()
true
Fetcher#sendFetches() 0ConsumerNetworkClient#hasPendingRequests()
职业：暂无
0 条评论
下一页
为你推荐
查看更多
