在 Apache Kafka 中，HW（High Watermark，高水位）和LEO（Log End Offset，日志末端偏移量）是两个核心概念，它们共同保障了 Kafka 的数据一致性、可靠性与可见性。理解它们的关系对掌握 Kafka 副本机制至关重要。
一、基本定义
| 概念 | 含义 |
|---|---|
| LEO（Log End Offset） | 表示当前副本（Replica）日志中下一条待写入消息的 offset。即：已有消息的最大 offset + 1。例如 LEO=10 表示已写入 [0, 9] 共 10 条消息。 |
| HW（High Watermark） | 表示已被所有 ISR（In-Sync Replicas）副本成功复制的消息的最高 offset。消费者只能消费 offset < HW 的消息，以确保读取的是“已提交”且“多副本一致”的数据。 |
✅ 简单记忆：
- LEO= “我写到哪了”（本地进度）
- HW= “大家都确认到哪了”（全局共识）
二、HW 与 LEO 的关系
1.HW ≤ LEO
- 因为 HW 是基于 ISR 中所有副本的 LEO 计算得出的，而 Leader 自身的 LEO 通常最大。
- 所以 HW永远不会超过任何 ISR 副本的 LEO，自然也不会超过 Leader 的 LEO。
2.HW = min(所有 ISR 副本的 LEO)
- Leader 会持续监控所有ISR 集合中的 Follower 副本的 LEO。
- 分区的 HW 就是这些副本 LEO 的最小值。
HW = min(Leader.LEO, Follower1.LEO, Follower2.LEO, ...) - 只有当所有 ISR 副本都复制了某条消息，该消息的 offset 才会被包含进 HW。
3.消费者只能读取 offset < HW 的消息
- 这是为了防止消费者读到“尚未被多数副本确认”的数据，避免在 Leader 切换时出现数据丢失或重复。
- 例如：HW=5，则消费者最多只能读到 offset=4 的消息。
三、工作流程示例
假设一个分区有 3 个副本（1 Leader + 2 Follower），初始状态：
| 副本 | LEO | HW |
|---|---|---|
| Leader | 0 | 0 |
| Follower A | 0 | 0 |
| Follower B | 0 | 0 |
生产者发送消息 offset=0
- Leader 写入，LEO → 1
- Follower 尚未同步 → LEO 仍为 0
- 此时 ISR 中最小 LEO = 0 →HW 保持 0
- 消费者看不到这条消息！
Follower A 和 B 完成同步
- Follower A LEO → 1，Follower B LEO → 1
- ISR 最小 LEO = 1 →HW 更新为 1
- 消费者现在可以消费 offset=0 的消息。
四、关键特性
| 特性 | 说明 |
|---|---|
| 数据可见性控制 | HW 决定了消费者能读到哪里，保证“已提交”语义 |
| 容错机制 | 若某个 Follower 落后太多（如网络中断），会被踢出 ISR，不再参与 HW 计算，避免拖慢整体进度 |
| Leader 切换安全 | 新 Leader 必须截断日志至其 HW（即旧 HW），防止暴露未被确认的数据 |
| HW 更新延迟 | HW 通常在 Follower 发起 Fetch 请求时由 Leader 返回并更新，存在一定延迟 |
五、图解关系（简化）
Offset: 0 1 2 3 4 5 6 [==== committed ====][-- uncommitted --] ↑ ↑ HW=5 LEO=7[0, 4]：可被消费者安全读取（offset < HW）[5, 6]：已写入 Leader，但未被所有 ISR 确认，不可见
六、常见误区
- ❌ “HW 是 Leader 的 LEO” → 错！HW 是 ISR 中最小 LEO。
- ❌ “消费者能读到最新写入的消息” → 错！必须等 ISR 同步完成，HW 推进后才能读。
- ✅HW 保证的是“已复制”而非“已持久化”—— 即使磁盘故障，只要 ISR 中有副本存活，数据就不会丢。
总结
HW 是 Kafka 实现“一致性读”和“高可用”的基石，而 LEO 是每个副本的本地写入进度。HW 由 ISR 中最慢的 LEO 决定，消费者只能看到 HW 之前的数据。
这种设计在性能与一致性之间取得了良好平衡，也是 Kafka 能成为高吞吐、可靠消息系统的关键之一。
