kafka
2021-04-03 22:38:01 5 举报s
作者其他创作
大纲/内容
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
0 条评论
下一页
