Kafka生产者架构 - Sender

文章目录 前言 源码分析 run() runOnce() sendProducerData(...) sendProduceRequest(...) handleProduceResponse(...) 前言 本文解析生产者流程图中的步骤5、6、7。 概述：Sender线程负责将ProducerBatch列表构建ProducerRequest，然后用来构造ClientRequest，最后将其交给N

>>阅读原文<<