kafka 生产者整体结构
2020-07-28 09:31:33 0 举报kafka生产者整体结构
作者其他创作
大纲/内容
分区器Pertitioner
分区 1
kafkaProducer
Request
9
2
node1
1
kakfa Cluster
11 清理
5
NetworkClient
ProducerBatch
node n
8 提交给Selector准成发送
主线程
3
6
分区 2
拦截器ProducerInterceptors
消息累加器 RecordAccumulator
分区 3
4
sender
7 缓存
Selector
序列化器Seriallizer
创建 Request
10Requset
Sender 线程
收藏
0 条评论
下一页
