Kafka源碼之KafkaProducer分析

我們先通過一張圖來了解一下KafkaProducer發送消息的整個流程： 1、ProducerInterceptors對消息進行攔截。 2、Serializer對消息的key和value進行序列化 3、Partitioner爲消息選擇合適的Partition 4、RecordAccumulator收集消息，實現批量發送 5、Sender從RecordAccumulator獲取消息 6、構造Clie

>>阅读原文<<