共计 390 个字符，预计需要花费 1 分钟才能阅读完成。
外围组件
1.ProducerInterceptors 拦截器
2.Sender 发送线程
3.Cluster 集群信息（结点、主题、分区）
4.ProducerMetadata 生产者元数据
5.RecordAccumulator 音讯缓冲累加器
6.Serializer 序列化器
7.Partitioner 分区器
send() 产生音讯流程
1.ProducerInterceptors 拦挡音讯，调用 onSend() 办法
2. 调用 doSend()，真正开始产生音讯流程
3.waitOnMetadata，发送音讯前确保主题分区元数据可用
4. 调用 Serializer 对 key 和 value 序列化
5. 调用 Partitioner 进行分区路由抉择（哈希 / 轮询 / 粘性）
6. 调用 RecordAccumulator 将音讯放到缓冲区中队列的 RecordBatch 中
7. 唤醒 Sender 线程，从缓冲区拉取音讯，将数据发送到网络中去
正文完