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

>>阅读原文<<