Selector
获取数据
KafkaClient
12
Producerbatch
11
请求
7
InFightRequest
ProducerIntercept
2
1
ClientRequest
6
3
kafkaProducer
10
partitioner
Serializer
sender线程
4
5
Broker
9
响应
NetWorkClient
8
RecordAccumacter(缓冲区默认32m)Deque(队列-默认16KB)→分区0Deque(队列-默认16KB)→分区1Deque(队列-默认16KB)→分区2
Broker
