章节导读:生产者详解
定位说明
本章深入 Kafka Producer 的完整工作机制。在前三章建立了 Topic/Partition/Offset 的认知基础上,本章回答"消息是怎么进入 Kafka 的"——从客户端的 API 调用到 Broker 端的磁盘写入,覆盖分区路由、批处理攒批、ACK 确认、幂等和事务等核心机制。
学习路线
文件关系
| 文件 | 定位 | 核心问题 |
|---|---|---|
Producer_概述.md | Producer 的架构、构造方式、消息结构 | Producer 在 Kafka 中扮演什么角色? |
Producer_分区策略.md | Key/Value 路由、Sticky Partitioner、自定义分区 | 消息怎么决定去哪个分区? |
Producer_发送机制.md | 发送流程、批处理、ACK、重试 | 消息怎么到 Broker?怎么确认? |
Producer_幂等与事务.md | 幂等生产者、事务消息、精确一次语义 | 如何保证消息不重复、不丢失? |
Producer_配置.md | 关键配置参数速查表与调优建议 | 什么场景该调什么参数? |