Kafka源碼之Sender分析

我們先來介紹一下Sender發送消息的整個流程：首先根據RecordAccumulator的緩存情況，利用ready篩選出可以向哪些節點發送消息，然後根據生產者和各個節點的連接愛你概況，過濾Node節點，之後，生成相應的請求，這裏要特別注意的是每個Node節點只生成一個請求，最後，調用NetWorkClient將請求發送出去。 1、從Metadata獲取Kafka集羣元數據 2、調用RecordA

>>阅读原文<<