1、Kafka Producer初始化核心流程

sender线程

RecordBatch

ClientRequest

RecordAccumulater缓存

Dqueue 批次队列

Selector

拉取数据

执行网络请求：请求元数据、发送数据等

NetworkClient，接受请求

执行绑定的回调函数

Serializer

KafkaChannel

返回响应

Partitioner

KafkaProducer

一个主题三个分区的情况，这里展示的是kafka producer初始化的时候的流程以及重要组件的交互

Kafka 集群，server端

缓存中，每个分区对应一个队列，队列中存储多个batch；缓存默认大小32M，每个batch默认16Kb

消息加入缓存

ProducerIntercepter

sender线程负责拉取元数据，以及从accumulater中拉取消息，通过自己封装的NetworkClient组件与服务端联系，发送和接受请求