分析使用Kafka生产者发送消息的主流程
暂不涉及事务型发送
名词解释:
- KafkaProducer
消息生产者ProducerRecord
消息载体ProducerInterceptor
发送消息拦截器ClusterAndWaitTime
Cluster: Kafka集群对象, 记录集群leader信息KeySerializer
消息Key的序列化器,序列化为二进制数组ValueSerializer
消息值的序列化器Partitioner
分区选择器,决定消息发送到哪个分区RecordAccumulator
消息累加器,内部使用Deque来缓存要发送的消息*KafkaProducer#Sender
发送者线程,负责把Accumulator存储的消息推给Kafka结点
时序图:
1. 把消息投递到消息累加器
待续



