Kafka第三篇之一条消息是如何被存储到Broker上的长尾？

本文共计1881个文字，预计阅读时间需要8分钟。

原文：本文字我们从以下4个方面来探讨一条消息如何被准确地发送到Broker的partition上。

1.客户端组件

2.客户端端缓存存储模型

3.确定消息的partition位置

4.发送线程的工作原理及客户端组件

改写后：探讨消息如何精确送达Broker partition的四个关键点：

1.客户端组件

2.缓存存储模型

3.确定partition位置

4.发送线程原理与客户端组件

本文我们从以下 4 个方面来探讨下一条消息如何被准确的发送到 Broker 的 partition 上。

1. 客户端组件

2. 客户端缓存存储模型

3. 确定消息的 partition 位置

4. 发送线程的工作原理

---

客户端组件

• KafkaProducer:

KafkaProducer 是一个生产者客户端的进程，通过该对象启动生产者来发送消息。

• RecordAccumulator:

RecordAccumulator 是一个记录收集器，用于收集客户端发送的消息，并将收集到的消息暂存到客户端缓存中。

• Sender:

Sender 是一个发送线程，负责读取记录收集器中缓存的批量消息，经过一些中间转换操作，将要发送的数据准备好，然后交由 Selector 进行网络传输。