Kafka源码之Sender分析

我们先来介绍一下Sender发送消息的整个流程：首先根据RecordAccumulator的缓存情况，利用ready筛选出可以向哪些节点发送消息，然后根据生产者和各个节点的连接爱你概况，过滤Node节点，之后，生成相应的请求，这里要特别注意的是每个Node节点只生成一个请求，最后，调用NetWorkClient将请求发送出去。 1、从Metadata获取Kafka集群元数据 2、调用RecordA

>>阅读原文<<