09. Kafka Producer 生产者详解

本章深入分析 Kafka Producer 客户端的实现机制，包括消息发送流程、批量处理、压缩机制、幂等性和事务支持等核心功能。

章节目录

文档	内容	难度
01-producer-overview.md	Producer 架构概述	⭐
02-record-accumulator.md	RecordAccumulator 缓冲区	⭐⭐⭐
03-sender-thread.md	Sender 线程详解	⭐⭐⭐
04-metadata-management.md	元数据管理	⭐⭐
05-partitioner.md	分区器实现	⭐⭐
06-interceptors.md	拦截器机制	⭐
07-transaction-manager.md	事务管理器	⭐⭐⭐
08-producer-config.md	配置详解	⭐
09-producer-practical-guide.md	实战指南	⭐⭐

核心概念速查

Producer 架构

┌─────────────────────────────────────────────┐
│               KafkaProducer                 │
├─────────────────────────────────────────────┤
│  1. send() → 序列化 → 分区计算               │
│  2. → RecordAccumulator (缓冲区)            │
│  3. → Sender 线程批量发送                   │
└─────────────────────────────────────────────┘

关键配置

配置	默认值	说明
bootstrap.servers	-	Broker 地址列表
key.serializer	-	Key 序列化器
value.serializer	-	Value 序列化器
acks	1	确认机制
retries	0	重试次数
batch.size	16384	批量大小
linger.ms	0	发送延迟
buffer.memory	33554432	缓冲区大小
enable.idempotence	false	幂等性
transactional.id	null	事务 ID

学习路径

快速了解

1. 架构概述
2. 配置详解

深入理解

1. RecordAccumulator 缓冲区
2. Sender 线程
3. 元数据管理
4. 分区器

高级特性

1. 拦截器
2. 事务管理器

相关章节

• 03. 日志存储 - 消息存储机制
• 10. Consumer 消费者 - 消费者客户端
• 11. 网络协议 - Producer 请求协议

---

上一章: 08. 其他下一章: 10. Consumer 消费者