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