KafkaProducer介紹

一 生產者發送消息到broker的流程 1.1 ProducerIntercptor對消息進行攔截 1.2 Serialzer對key和value進行序列化 1.3 Partitioner對消息選擇合適的分區 1.4 RecordAccumulator收集消息，實現批量發送 1.5 Sender從RecordAccumulator獲取消息 1.6 構造ClientRequest 1.7 將Clie

>>阅读原文<<