sender分析之创建请求

一 Sender run方法调用流程 # 从Metadata获取集群元数据 # 调用RecordAccumulator.ready方法，根据RecordAccumulator的缓存情况，选出可以向哪些Node发送消息，返回ReadyCheckResult对象 # 如果ReadyCheckResult存在某些分区没有leader副本，则调用Metadata的requestUpdate方法，标记需要更

>>阅读原文<<