kafka-clients源碼分析二:producer發送消息架構

1. ProducerIntercptor對消息進行攔截 2. Serialzer對key和value進行序列化 3. Partitioner對消息選擇合適的分區 4. RecordAccumulator收集消息,實現批量發送 5. Sender從RecordAccumulator獲取消息 6 構造ClientRequest 7 將ClientRequest交給Network,準備發送 8 Net
相關文章
相關標籤/搜索