《Java 消息中间件·Kafka 内核与客户端》目录与学习路径

这本书的骨架

卷一回答一个问题：一条消息从 send() 调用到落进日志文件，中间发生了什么，为什么有时候不按你以为的方式发生。

为了回答这个问题，全书分成五个部分，前三部分是「理解」，后两部分是「使用与维护」：

前两部分是概念密度最高的地方。第三部分是源码，读起来慢但一次性收益最大。第四、五部分可以当手册查。

每一章回答的那个问题

写目录的时候，最没用的是只列标题。所以这里给每章配一个「它到底在回答什么」：

如果你手上正有一个具体问题，直接看最后一列，比从头读快。

第一部分：消息系统与实验底座

这一部分建立两件事：消息系统的直觉，以及一套能反复用的实验环境。

第 1 章不需要环境，读完就能建立直觉。第 2 章开始需要容器，所以 2.1 同时承担「实验环境搭建」的职责——如果这一步跑不通，后面的实验都做不了。

第 3 章讲生产者，是全书第一次动手写客户端代码。它的前置只有 1.2（分区）和 1.3（语义），不依赖服务端机制。

第二部分：服务端机制

这一部分进入 broker 内部。它不需要写太多客户端代码，但需要三类实验：单节点、三节点、以及「杀掉一个节点」的破坏性操作。

第 4 章是三节点实验的核心。4.1 建立 LEO/HW 的关系，4.2 用「杀一个 broker 还能写、杀两个就不能写」把这个关系变成可观测的事实，4.3 讲选举策略。

第 5 章讲 KRaft。这里有一个版本陷阱：4.x 已经彻底移除 ZooKeeper，所有命令用 --bootstrap-server，--zookeeper 参数不存在。如果你在别处看到「用 --zookeeper 连集群」，那是 3.x 的写法。

第 6 章讲消费者协调。6.2 和 6.3 是同一件事的两代实现，读的时候要分清「classic 协议的行为」和「新协议的行为」，两者在再平衡停顿上的表现不同。

第三部分：客户端源码

这一部分最慢，也最值。它要求读者愿意打开 sources jar，跟着方法调用读下去。

这一部分有一个反复出现的提醒：不要凭 3.x 的印象写 4.x 的源码。消费者的实现、Fetcher 的职责、group.protocol 的分支，在 4.x 都变了。每一节都会给出 grep 命令和类文件大小，读者可以自己复核。

第四部分：存储与性能

这一部分回答「为什么快」和「快到哪里为止」。

第 12 章会明确写：本机的压测数字只能做相对比较，不能做容量结论。这不是谦虚，是这台机器 load 常年在十几到二十几之间波动决定的。

第五部分：运维与故障

这一部分最接近日常工作。它的组织方式不是「知识点」，是「动作」。

附录

附录 A 里的端口、参数都是本机实际用过的，可以直接复制。附录 B 的 compose 文件就是本书实验用的那一份。

三条阅读路径

路径一：顺序通读（约 30 小时）

1.1 → 1.2 → 1.3 → 2.1 → …… → 15.3。适合想建立完整机制理解的人。第 1–3 章大约 6 小时，第 4–6 章 8 小时，第 7–9 章源码 8 小时，第 10–15 章 8 小时。

路径二：机制跳读（约 12 小时）

只读第 1、4、6、7、8 章。这五章覆盖三个最高频的疑问：为什么消费者会重复、为什么再平衡会停顿、为什么分区数不能乱加。读完可以跳过第 2、3、5 章的细节，需要时再回查。

路径三：值班查表（按需）

附录 A 的命令 + 第 14 章的故障图谱 + 15.1 的指标阈值。这条路径不追求理解，只追求「现在该敲什么命令」。

每节末尾的「判据」是什么

本书每一节结尾附近都会有一个小段落，标题通常是「本节判据」或「怎么判断」。它回答的不是「讲完了吗」，而是「什么现象出现，说明你真的理解了」。

举三个例子：

• 1.2 节的判据是：你能否解释「为什么 5 条消息按顺序发出，消费者看到的却是 book-3 在前」。
• 4.2 节的判据是：看完 NOT_ENOUGH_REPLICAS 之后，你是否能说出「此时再减一个副本会怎样」。
• 8.3 节的判据是：你能否指出自动提交在哪个时间点可能丢掉一批已处理的记录。

这个设计来自一个观察：技术书读完之后最常说的一句话是「好像懂了」。判据的作用是把它变成一个可以自己回答的问题。答不出来，说明这一节需要重读或重跑实验。

和其它书的关系

这本卷属于《Java 消息中间件》三卷本的第一卷。三卷的关系是：

此外，下面几本书和本卷有交叉，但角度不同：

• 《Java 并发编程·性能诊断与事故》 ：讲线程、锁、GC 与容器配额。本卷讲的是跨进程的消息链路，那本讲的是单进程内的并发。读第 11、12 章时如果对 CPU 与内存的观测手段不熟，可以对照那本的诊断工具章节。
• 《Java 网络编程基础》 ：讲 Socket、NIO、HTTP/2 与 TLS。Kafka 的协议建立在 TCP 之上，第 11.1 节讲网络线程时会假设你了解基本的 TCP 语义。
• 《Java 虚拟机原理与性能调优》 ：讲 GC 与内存布局。Kafka 客户端大量使用堆外内存与页缓存，第 10 章会引用那本的概念。

读之前需要的前置知识

这本书不假设你已经是 Kafka 专家，但假设你具备三样东西：

不需要的前置：不需要用过 ZooKeeper（4.x 已经没有它），不需要装过 Kafka（第 2.1 节从零开始），不需要懂 Scala（本书只读 clients 模块，纯 Java）。

有一个前置不建议带进来：其它版本 Kafka 的既有印象。3.x 到 4.x 的变化足够大，尤其是消费者实现和 KRaft 的默认化。带着旧印象读，容易在「我记得应该是……」的地方卡住。每节遇到这类变化时会明确标出「4.x 与 3.x 的差异」。

4.x 与旧教材的七处不同

如果你读过 2.x 或 3.x 时代的 Kafka 材料，下面这几处会让你在实验里直接卡住。本书在对应章节会逐条展开，这里先给一张速查表：

这张表不是让你背，是让你在遇到「命令报错」时先来这里对一眼。本书所有实验都是在 4.3.0 上跑的，凡是涉及行为变化的地方都会显式标注。

哪些实验可以跳过

不是每一节都需要动手。下面这张表说明每个实验的性质，方便你按时间预算取舍：

「破坏性操作」那一行的措辞是刻意的。读别人写的「杀掉 leader 之后 ISR 从 3 变成 2」，和自己在终端里看着 --describe 的输出从 Isr: 2,3,1 变成 Isr: 3,1，理解深度完全不同。这一类实验，本书建议一定自己跑。

一个使用建议

这本书的每一节都按同一个结构写：先给一个具体问题，再给机制，再给实验，最后给判据。

如果你时间有限，只读每节开头的「问题」和结尾的「判据」，中间跳过实验，也能得到一个可用的结论。但如果你要拿这个结论去做生产决策，请至少把实验跑一遍——这本书里没有一个数字是编的，其中不少也和「常识」相反。

另一个建议是：遇到与自己经验冲突的段落，先别急着判它错。本书有若干结论初看反直觉，比如「send() 成功不代表消费者能读到」「acks=all 仍然可能丢」「分区数加到某个点之后整体吞吐反而下降」。这些都不是笔误，而是机制决定的。每一处都给了可复现的命令，请先跑，再下结论。

如果跑出来的结果和书里不一样，那也可能不是书错了，而是你的版本、参数或机器状态不同。把这三种差异记录下来，本身就是一次很好的学习。

从第 1.1 节 开始。