1、Kafka Producer初始化核心流程
2021-07-20 15:42:32 7 举报Apache kafka生产者初始化的流程
作者其他创作
大纲/内容
sender线程
RecordBatch
ClientRequest
RecordAccumulater缓存
Dqueue 批次队列
Selector
拉取数据
执行网络请求：请求元数据、发送数据等
NetworkClient，接受请求
执行绑定的回调函数
Serializer
KafkaChannel
返回响应
Partitioner
KafkaProducer
一个主题三个分区的情况，这里展示的是kafka producer初始化的时候的流程以及重要组件的交互
Kafka 集群，server端
缓存中，每个分区对应一个队列，队列中存储多个batch；缓存默认大小32M，每个batch默认16Kb
消息加入缓存
ProducerIntercepter
sender线程负责拉取元数据，以及从accumulater中拉取消息，通过自己封装的NetworkClient组件与服务端联系，发送和接受请求
0 条评论
下一页
