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

Kafka生产者客户端整体架构如图: 整个生产者客户端主要有两个线程,主线程以及Sender线程。Producer在主线程中产生消息,然后通过拦截器,序列化器,分区器之后缓存到消息累加器RecordAccumulator中。Sender线程从RecordAccumulator中获取消息并发送到kafka中。 RecordAccumulator主要用来缓存消息,这样发送的时候进行批量发送以便减少相应
相关文章
相关标签/搜索