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()
