Kafka生产者流程
2020-10-20 09:54:29 0 举报kafka生产者流程
作者其他创作
大纲/内容
KafkaChannel
Partitioner(分区器)
RecordBatch
ClientRequest网络请求
message
读取数据
NetworkClient组件
生产者主线程
发送消息到缓存
sender线程
queue有序队列
ProducerInterceptor(拦截器)
返回响应
Serialier(序列化)
执行回调
RecordAcuumulator(缓存)
Selector组件执行网络请求
Kafka集群
Selector组件
收藏
0 条评论
下一页
