Kafka原理及其架構

消息在真正發往Kafka之前，有可能需要經歷攔截器（Interceptor）、序列化器（Serializer）和分區器（Partitioner）等一系列的作用，那麼在此之後又會發生什麼呢？下面我們來看一下生產者客戶端的整體架構， 整個生產者客戶端由兩個線程協調運行，這兩個線程分別爲主線程和Sender線程（發送線程）。在主線程中由KafkaProducer創建消息，然後通過可能的攔截器、序列化器和

>>阅读原文<<