KafkaKafka Producer整体架构概述及源码分析

Posted 2021-08-07 九师兄

1.概述

转载并且补充：原文地址：https://blog.csdn.net/XU906722/article/details/104420045

本文基于Kafka 0.11 版本

2.整体架构

2.1 线程

整个 Kafka 客户端由两个线程协调运行，即Main线程和Sender线程。
在Main线程中由KafkaProducer创建消息，然后通过Interceptor、Serializer和Partitioner之后缓存到RecordAccumulator(消息累加器)中。
Sender线程 负责从RecordAccumulator中获取消息并发送到Kafka中。

<