Kafka生產者架構 - KafkaChannel 阿新 • • 發佈：2020-10-12 文章目錄 前言原始碼分析read()方法write()方法 前言 本文是Kafka生產者架構篇的最後一篇文章。主要分析底層的讀寫操作。 原始碼分析 從read()、write()方法中，不難看出核心方法是呼叫nio原生的 ScatteringByteChannel#read(ByteBuffer)、GatheringByteChannel#write(ByteBuffer[])方法。 read()方法 核心方法是ScatteringByteChannel#read(ByteBuffer) write()方法 核心方法是GatheringByteChannel#write(ByteBuffer[])
