内容简述:
分析使用Kafka生产者发送消息的主流程
 暂不涉及事务型发送
名词解释:
- KafkaProducer
 消息生产者
- ProducerRecord
 消息载体
- ProducerInterceptor
 发送消息拦截器
- ClusterAndWaitTime
 Cluster: Kafka集群对象
- KeySerializer
 消息Key的序列化器,序列化为二进制数组
- ValueSerializer
 消息值的序列化器
- Partitioner
 分区选择器,决定消息发送到哪个分区
- RecordAccumulator
 消息累加器,内部使用Deque来缓存要发送的消息
时序图:
1. 把消息投递到消息累加器











