kafka生产者客户端架构和处理流程

Kafka生产者客户端总体架构如图： web 整个生产者客户端主要有两个线程，主线程以及Sender线程。Producer在主线程中产生消息，而后经过拦截器，序列化器，分区器以后缓存到消息累加器RecordAccumulator中。Sender线程从RecordAccumulator中获取消息并发送到kafka中。 RecordAccumulator主要用来缓存消息，这样发送的时候进行批量发送以便

>>阅读原文<<