Kafka中一条消息是如何在第三篇中具体存储到Broker的？

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

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

1.客户端组件

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

3.确定消息的partition位置

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

改写后：探讨消息如何精确送达Broker的partition，涉及以下4个方面：

1.客户端模块

2.客户端缓存存储模式

3.确定消息partition的位置

4.发送线程的工作机制及客户端模块

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

1. 客户端组件

2. 客户端缓存存储模型

3. 确定消息的 partition 位置

4. 发送线程的工作原理

---

客户端组件

• KafkaProducer:

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