kafka生產者客戶端架構和處理流程

Kafka生產者客戶端總體架構如圖： web 整個生產者客戶端主要有兩個線程，主線程以及Sender線程。Producer在主線程中產生消息，而後經過攔截器，序列化器，分區器以後緩存到消息累加器RecordAccumulator中。Sender線程從RecordAccumulator中獲取消息併發送到kafka中。 RecordAccumulator主要用來緩存消息，這樣發送的時候進行批量發送以便

>>阅读原文<<