当前位置：首页 > 科技 > 软件

九张图带你理解 Kafka 中高水位ＨＷ

来源：责编：时间：2024-07-03 10:09:50 265观看

导读大家好，我是君哥。Kafka 高水位（简称 HW）是 Kafka 中非常重要的一个概念，今天来聊一聊 HW。1 HW 简介HW 是 Kafka 中 Offset 的一个值，HW 作为一个边界，Offset 小于 HW 的消息被称为已提交消息，这部分消息可以被消费者进行拉

大家好，我是君哥。

Kafka 高水位（简称 HW）是 Kafka 中非常重要的一个概念，今天来聊一聊 HW。

1 HW 简介

HW 是 Kafka 中 Offset 的一个值，HW 作为一个边界，Offset 小于 HW 的消息被称为已提交消息，这部分消息可以被消费者进行拉取消费，大于等于 HW 的消息被称为未提交消息，不能被消费者拉取。如下图：

图片

Offset 小于 108 的消息可以被消费者消费，Offset 大于等于 108 的消息不能被消费者消费。

2 LEO 简介

Kafka 中跟 Offset 相关的还有一个重要概念叫 LEO（Log End Offset）。LEO 表示 Offset 中的最后一个位置，也就是新消息写入的第一个位置，这个位置还没有消息。比如下图中的 114 这个位置，新消息写入时会从这个位置开始存储。

图片

3 HW 更新机制

对于 Kafka 的一个分区来说，分区的所有副本都有 HW 和 LEO 这 2 个重要属性，不光是 Leader 副本。但是 Leader 副本的 HW 值被作为整个分区的 HW。

因此，分区每个副本所在的 Broker 都保存了自己的 HW 和 LEO 值，而 Leader 副本所在的 Broker 节点还保存了 Follower 副本的 HW 和 LEO。

注意：这里说的 Follower 必须跟 Leader 保持同步，一般用 2 个条件来判断：

Follower 在 ISR 集合中；
Follower 中 LEO 值落后于 Leader LEO 值的时间，不超过参数(replica.lag.time.max.ms)的值，默认 10s。

如下图，partition-test 这个分区有 3 个副本，Leader 和 Follower1、Follower2，Follower1 和 Follower2 所在的 Broker1 上保存了自己的 HW 和 LEO，而 Leader 所在的 Broker0 不仅保存了自己的 HW 和 LEO，还保存了 Follower1 跟 Follower2 的 HW 和 LEO。

图片

3.1 Follower 更新

Broker1 和 Broker2 作为分区的 Follower 副本，会从 Leader 拉取消息，写入本地磁盘，然后更新 LEO。更新成功 LEO 后，比较自己的 LEO 值跟 Leader 副本发送的 HW 值，取较小的作为自己的 HW。如下图：

图片

3.2 Leader 更新

从 3.1 中的图可以看到，Leader 收到 Follower 拉取消息请求后，会根据 Follower 副本发送的拉取请求中的 Offset 更新本地保存的 Follower 的 LEO。同时 leader 会更新自己的 HW = min LEO of｛Leader、Follower1、Follower2｝。

需要注意的是，Leader 是不能更新 Follower 的 HW 的。

下面看一下 Leader 副本收到生产者发送的消息时是怎样更新自己的 LEO 和 HW 的。如下图：

图片

4 一个示例

下面以 Leader 只有一个 Follower 的场景来说明 LEO 和 HW 的更新过程。

初始状态，Leader 所在的 Broker 节点保存的 Leader 的 LEO 和 HW 都是 0，保存的 Follower 的 LEO = 0。

图片

生产者发送一条消息后，Leader 节点更新 LEO = 1，此时 Leader 的 HW 是 0。Follower 还没有发起拉取请求，所以 Follower 的 LEO 任然是 0，Leader 的 HW 是 0。

图片

Follower 第一次拉取消息，发送给 Leader 的 Offset = 0，Leader 节点收到请求后，因为 Offset = 0，所以本地保存的 Follower LEO 不变。Leader 节点返回消息给 Follower，Follower 节点写入消息后更新自己的 LEO = 1。

图片

Follower 第二次拉取消息，发送给 Leader 的 Offset = 1，Leader 节点收到请求后，更新本地保存的 Follower LEO = 1，更新自己的 HW = 1 并返回给 Follower，Follower 收到 Leader 发送的 HW 后更新自己的 HW = 1。

图片

总结

高水位 HW 这个概念在 Kafka 中标记消息是否可以被消费者消费，这个概念跟 LEO 有着重要的关系。本文介绍了 LEO 和 HW 的更新机制，希望对你理解 HW 有所帮助。

本文链接：http://www.28at.com/showinfo-26-98413-0.html九张图带你理解 Kafka 中高水位ＨＷ

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇： K8s 也有设计模式？你知道吗？

下一篇： Switch语句中使用String类型的实现原理

标签：

热门焦点

Rust中的高吞吐量流处理

作者 | Noz编译 | 王瑞平本篇文章主要介绍了Rust中流处理的概念、方法和优化。作者不仅介绍了流处理的基本概念以及Rust中常用的流处理库，还使用这些库实现了一个流处理程序
一篇聊聊Go错误封装机制

%w 是用于错误包装（Error Wrapping）的格式化动词。它是用于 fmt.Errorf 和 fmt.Sprintf 函数中的一个特殊格式化动词，用于将一个错误（或其他可打印的值）包装在一个新的错误中。使
如何使用JavaScript创建一只图像放大镜？

译者 | 布加迪审校 | 重楼如果您曾经浏览过购物网站，可能遇到过图像放大功能。它可以让您放大图像的特定区域，以便浏览。结合这个小小的重要功能可以大大改善您网站的用户体验
电视息屏休眠仍有网络上传爱奇艺被质疑“薅消费者羊毛”

记者丨宁晓敏见习生丨汗青出品丨鳌头财经（theSankei）前不久，爱奇艺发布了一份亮眼的一季报，不仅营收和会员营收创造历史最佳表现，其运营利润也连续6个月实现增长。自去年年初
重估百度丨大模型，能撑起百度的“今天”吗?

自象限原创作者｜程心罗辑2023年之前，对于自己的“今天”，百度也很迷茫。“新业务到 2022 年底还是 0，希望 2023 年出来一个 1。”这是2022年底，李彦宏
微博大门常打开，迎接海外画师漂洋东渡

作者:互联网那些事“起猛了，我能看得懂日语了”。“为什么日本人说话我能听懂？”“中文不像中文，日语不像日语，但是我竟然看懂了”…&hell
iQOO Neo8 Pro即将开售：到手价3099元起安卓性能最强旗舰

5月23日，iQOO如期举行了新品发布会，全新的iQOO Neo8系列也正式与大家见面，包含iQOO Neo8和iQOO Neo8 Pro两个版本，其中标准版搭载高通骁龙8+，而Pro版更
iQOO Neo8 Pro评测：旗舰双芯加持最强性能游戏旗舰

【Techweb评测】去年10月，iQOO推出了一款Neo7手机，该机搭载了联发科天玑9000+，配备独显芯片Pro+，带来了同价位段最佳的游戏体验，一经上市便受到了诸多用
回归OPPO两年，一加赢了销量，输了品牌

成为OPPO旗下主打性能的先锋品牌后，一加屡创佳绩。今年618期间，一加手机全渠道销量同比增长362%，凭借一加 11、一加 Ace 2、一加 Ace 2V三款爆品，一加

九张图带你理解 Kafka 中高水位ＨＷ

1 HW 简介

2 LEO 简介

3 HW 更新机制

3.1 Follower 更新

3.2 Leader 更新

4 一个示例

总结

Rust中的高吞吐量流处理

一篇聊聊Go错误封装机制

如何使用JavaScript创建一只图像放大镜？

电视息屏休眠仍有网络上传爱奇艺被质疑“薅消费者羊毛”

重估百度丨大模型，能撑起百度的“今天”吗?

微博大门常打开，迎接海外画师漂洋东渡

iQOO Neo8 Pro即将开售：到手价3099元起安卓性能最强旗舰

iQOO Neo8 Pro评测：旗舰双芯加持最强性能游戏旗舰

回归OPPO两年，一加赢了销量，输了品牌

最新推荐

猜你喜欢

热门推荐

相关资讯

九张图带你理解 Kafka 中高水位 ＨＷ

1 HW 简介

2 LEO 简介

3 HW 更新机制

3.1 Follower 更新

3.2 Leader 更新

4 一个示例

总结

最新推荐

猜你喜欢

热门推荐

相关资讯

九张图带你理解 Kafka 中高水位ＨＷ