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

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

>>阅读原文<<