0
点赞
收藏
分享

微信扫一扫

Kafka源码分析02-生产者

玩物励志老乐 2022-03-30 阅读 34
kafka

内容简述:

分析使用Kafka生产者发送消息的主流程
暂不涉及事务型发送


名词解释:

  1. KafkaProducer
    消息生产者
  2. ProducerRecord
    消息载体
  3. ProducerInterceptor
    发送消息拦截器
  4. ClusterAndWaitTime
    Cluster: Kafka集群对象
  5. KeySerializer
    消息Key的序列化器,序列化为二进制数组
  6. ValueSerializer
    消息值的序列化器
  7. Partitioner
    分区选择器,决定消息发送到哪个分区
  8. RecordAccumulator
    消息累加器,内部使用Deque来缓存要发送的消息

时序图:

1. 把消息投递到消息累加器

在这里插入图片描述


待续

举报

相关推荐

0 条评论