sender分析之創建請求

一 Sender run方法調用流程 # 從Metadata獲取集羣元數據 # 調用RecordAccumulator.ready方法,根據RecordAccumulator的緩存情況,選出可以向哪些Node發送消息,返回ReadyCheckResult對象 # 如果ReadyCheckResult存在某些分區沒有leader副本,則調用Metadata的requestUpdate方法,標記需要更
相關文章
相關標籤/搜索