doSend
sendProduceRequest
ProducerBatch
Deque
InFlightRequest
accumulator
onsend
ProduceRequest
drain
ProducerRecord
run
interceptors
sender
send
recordAccumulator.drain
newClientRequest
valueSerializer
node1
poll
node2
keySerializer
partitionRecords
sendProduceRequests
runOnce
future
add inFlightRequest into inFlightRequests
tryAppend
add
ioThread
client
drain some ProducerBatches from accumulator's batches to sender's inFlightBatches
addToInflightBatches
partition
inFlightRequests
append
kafkaProducer
serialize
main线程
sendProducerData
serialize
b:TopicPartitionb IN node2
a:TopicPartitiona IN node1
Transfer the record batches into a list of produce requests(ClientRequest) on a per-node basis
addToInflightBatchessendProduceRequest
start
c:TopicPartitionc IN node1
