news 2026/6/23 8:55:26

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/23 19:03:04

基于Spring Boot人才招聘管理系统

基于Spring Boot人才招聘管理系统 是一个基于Spring Boot框架构建的人力资源管理工具&#xff0c;旨在为企业提供高效、便捷的人才招聘和管理解决方案。以下是对该系统的详细介绍&#xff1a; 一、系统概述 Spring Boot人才招聘管理系统集成了职位发布、简历筛选、面试安排、聘…

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

国内容易上手的claudecode一键配置指南

还在为如何配置claude code发愁吗&#xff1f;通过下面简单三步&#xff0c;小白也只需几分钟即可让你用上官方正版的claude code&#xff01; 一、前置组件安装 1.1 git安装 下载git 建议默认安装c盘 以防报错 访问https://git-scm.com/install/windows&#xff0c;选择适合…

作者头像 李华
网站建设 2026/6/23 17:29:13

复原IP地址

题目链接 93. 复原 IP 地址 - 力扣&#xff08;LeetCode&#xff09; 思路&#xff1a; 1.首先读懂题目&#xff0c;ip 地址需要满足的条件是 没有前导0&#xff0c;并不超过 255 2. 接下来我们就只需要把 这三个点&#xff0c;模拟的放入到 这个字符串中&#xff0c;会生…

作者头像 李华
网站建设 2026/6/23 13:31:39

Redis 发布订阅

Redis 发布订阅 概述 Redis 发布订阅(Publish/Subscribe)是 Redis 提供的一种消息发布和订阅的机制。它允许消息的发布者发布消息到频道(Channel),而订阅者可以订阅一个或多个频道,以便接收消息。这种机制常用于构建实时消息系统,如实时新闻推送、社交网络消息推送等。…

作者头像 李华
网站建设 2026/6/23 11:25:50

JQuery支持WebUploader完成百万文件断点续传的原理?

前端大文件上传系统&#xff08;纯原生JS实现&#xff09;—— 专治各种不服IE9的倔强开发者 各位前端老炮儿们&#xff0c;今天给大家带来一个能兼容IE9的20G大文件上传系统&#xff0c;保证让你的客户感动到哭&#xff08;或者吓跑&#xff09;。毕竟在这个Vue3横行的时代&a…

作者头像 李华