《kafka producer學習筆記7》-sender1

一 序 通過上一篇的分析《RecordAccumulator(3)》我們知道，主線程通過KafkaProducer.send()方法將消息放入RecordAccumulator中緩存，並沒有實際的網絡I/O操作。網絡操作是由Sender統一進行的。 sender發消息的大概流程。 用RecordAccumulator.ready()方法，根據RecordAccumulator的緩存情況，篩選出可以

>>阅读原文<<