Kafka在發送一條消息時經歷了什麼？

Kafka在發送一條消息到borker以前，須要通過過濾器，序列化器， 分區器。 整個生產者客戶端由兩個線程協調運行,這兩個線程分別爲主線程 和 Sender線程 。在主線程中由 KafkaProducer建立消息,而後經過可能的攔截器、序列化器和分區器的做用以後緩存到RecordAccumulator中 Sender 線程負責從 RecordAccumulator中獲取消息並將其發送到 Kafk

>>阅读原文<<