通过上一课时的介绍我们了解到，业务线程使用 KafkaProducer.send() 方法发送 message 的时候，会先将其写入RecordAccumulator 中进行缓冲，当 RecordAccumulator 中缓存的 message 达到一定阈值的时候，会由 IO 线程批量形成请求，发送到 kafka 集群。本课时我们就重点来看一下 RecordAccumulator 这个缓冲区的结构。

安装 JDKJDK 的安装非常简单，这里我们安装 JDK 8 即可（虽然 JDK 现在的新版本是 16，但是国内生产环境还有相当一大部分还是停留在 8 这个版本上）。首先到 JDK下载地址下载对应系统的 JDK 安装包即可，这里我使用的是 mac 系统，下载 dmg 文件即可。

Kafka 会按照一定的策略，将消息按照 key 值路由到指定的 partition 中，从而保证 key 相同的 message 全部写入同一 partition 中。