Kafka生產者之Sender分析

基於kafka2.x 版本 生產者局部架構圖   Sender線程run()步驟：場景驅動方式cluster中已有元數據 1、獲取元數據 2、判斷哪些partitinon有消息要發送，獲取分區號對應的broker主機 3、標誌還沒有拉取到元數據的topic 4、檢查與要發送數據的主機網絡是否建立好 5、有可能要發送的parttition有多個，有一些parttition的leader partit

>>阅读原文<<