【Kafka】Kafka Producer整体架构概述及源码分析 电玩女神 2022-10-19 14:00 112阅读 0赞 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70] # 1.概述 # 转载并且补充:原文地址:[https://blog.csdn.net/XU906722/article/details/104420045][https_blog.csdn.net_XU906722_article_details_104420045] 本文基于Kafka 0.11 版本 # 2.整体架构 # ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70 1] ## 2.1 线程 ## > 整个 Kafka 客户端由两个线程协调运行,即Main线程和Sender线程。 > 在Main线程中由KafkaProducer创建消息,然后通过Interceptor、Serializer和Partitioner之后缓存到RecordAccumulator(消息累加器)中。 > Sender线程 负责从RecordAccumulator中获取消息并发送到Kafka中。 < [watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70]: /images/20221004/a14100e0dda64527bd7cc050677a8b6f.png [https_blog.csdn.net_XU906722_article_details_104420045]: https://blog.csdn.net/XU906722/article/details/104420045 [watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMzgzNDM1_size_16_color_FFFFFF_t_70 1]: /images/20221004/6612df45e23b4a53bcb683d1a2a50fbc.png
还没有评论,来说两句吧...