news 2026/6/12 20:52:18

kafka--基础知识点--6.4--LSO

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
kafka--基础知识点--6.4--LSO

个人理解,可能有误,仅供参考

LSO: LastStableOffset,分区中第一个未完成事务的起始偏移量,或如果没有未完成事务则为HW。

LSO <= HW <= LEO

LSO起作用必须满足以下所有条件:

  • 同一个分区多个生产者[也可以只有一个]中必须至少有一个是事务生产者;
  • 该分区的消费者isolation.level参数值必须为read_committed

在 isolation.level=read_committed 模式下:

  • 消费者只能读取到 LSO 之前的消息
  • 如果事务未提交,LSO 会停留在第一个未提交事务的起始偏移量
  • 这意味着LSO 之后的所有消息(无论事务/非事务)都无法被读取
  • 直到生产者事务提交事务,消费者才能继续消费后边的消息

示例:
有两个生产者将消息发往同一分区,一个是事务生产者,一个是非事务生产者;该分区的消费者设置参数isolation.level=read_committed。分区接收到两个生产者消息的顺序可能如下:

# 事务提交前 偏移量: 0 1 2 3 4 消息: A B C D E 状态: ✓ ✗ ✓ ✗ ✓ # ✓=非事务 ✗=事务消息(未提交) HW: 5 # 所有消息都已复制到ISR LSO: 1 # 第一个未提交事务在偏移量1 消费者可见: 只有偏移量0的消息A 消费者被阻塞在偏移量1,无法读取1-4的任何消息 # 事务提交后 LSO: 5 # 事务提交后,LSO推进到HW 消费者可见: 消息A, B, C, D, E全部可见
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/11 22:47:50

Flutter:开启跨平台应用开发的新纪元

标题&#xff1a;Flutter&#xff1a;开启跨平台应用开发的新纪元 引言 在移动互联网高速发展的今天&#xff0c;用户对应用的性能、体验和交付速度提出了更高的要求。与此同时&#xff0c;开发者面临着为多个平台&#xff08;如 iOS、Android、Web 和桌面&#xff09;分别开…

作者头像 李华
网站建设 2026/6/13 7:26:46

9个AI写作工具,助你轻松搞定本科论文!

9个AI写作工具&#xff0c;助你轻松搞定本科论文&#xff01; 论文写作的“隐形助手”正在改变你的学习方式 在当今信息化时代&#xff0c;AI 技术已经渗透到我们生活的方方面面&#xff0c;而学术写作也迎来了全新的变革。对于本科生而言&#xff0c;撰写一篇高质量的本科论文…

作者头像 李华
网站建设 2026/6/12 19:14:36

彻底搞懂JavaScript块级作用域与函数作用域:var、let、const的核心区别

彻底搞懂JavaScript块级作用域与函数作用域&#xff1a;var、let、const的核心区别 在JavaScript中&#xff0c;作用域是控制变量访问权限的核心机制&#xff0c;直接影响代码的安全性、可维护性甚至运行结果。尤其是ES6引入块级作用域后&#xff0c;var、let、const 三者的作用…

作者头像 李华
网站建设 2026/6/10 13:00:06

【MongoDB实战】6.3 索引优化实战:慢查询解决

文章目录 《MongoDB实战入门》第6章 性能优化:索引与查询效率提升 6.3 索引优化实战:慢查询解决 6.3.1 识别慢查询:explain()方法分析查询执行计划 1. 核心概念铺垫 2. 实操:识别慢查询(准备测试数据+分析执行计划) 6.3.2 优化案例:为慢查询添加合适索引(对比优化前后)…

作者头像 李华