kafka生產者原理分析

生產者客戶端整體架構： ​ 整個生產者客戶端由兩個線程協調運行，這兩個線程分別爲主線程和Sender線程（發送線程）。在主線程中由KafkaProducer創建消息，然後通過可能的攔截器、序列化器和分區器的作用之後緩存到消息累加器（RecordAccumulator，也稱爲消息收集器）中。Sender線程負責從RecordAccumulator中獲取消息並將其發送到kafka中。 ​ Record

>>阅读原文<<