kafka 筆記二 kafka生產者

Kafka數據生產流程解析 1. Producer 創建時，會創建一個 Sender線程並設置爲守護線程。 2. 生產消息時，內部其實是異步流程；生產的消息先經過攔截器 -> 序列化器 ->分區器，然後將消息緩存在緩衝區（該緩衝區也是在 Producer創建時創建）。 3. 批次發送的條件爲：緩衝區數據大小達到 batch.size 或者linger.ms達到上限，哪個先達到就算哪個。 4. 批次

>>阅读原文<<