needRefreshCommits()
...
needsPartitionAssignment
refcount
autoCommitTask
assignFromSubscribed()
TopicPartition
List
pollNoWakeup()
fetchedRecords()
subscriptionType
interceptors
autoCommitEnabled
deserializer
paused
committed
poll()
Kafka Server
sendFetches()
topicPartition
Cluster
userAssignment
CompletedFetch
ConsumerNetworkClient
updateFetchPositions
网络
groupSubscription
KafkaConsumer
fetchedOffset
position
ensurePartitionAssignment()
partitionData
ensureFreshMetadata()
Metadata
resetOffsetsIfNeeded
assignment
:
topicPartitionState
subscription
currentThread
needsFetchCommittedOffsets
SubscriptionState
ConsumerCoordinator
List completedFetches
send()
