Kafka生产者架构 - NetworkClient

文章目录 前言 源码分析 send方法 poll方法 前言 本文解析生产者流程图中的NetworkClient部分的处理逻辑。 概述：本文主要解析NetworkClient对于请求的进一步处理以及消息发送到Kafka Cluster之后的后置处理，比如对请求完成的处理、响应完成的处理、断开连接的以及新加入连接的处理、超时请求的处理，最后记录相关信息，执行对应的回调，完成或者重试批次的处理。 源码分

>>阅读原文<<