中小型电子商务网站站长之家app
张小明 2026/1/1 14:24:15
中小型电子商务网站,站长之家app,网络营销方案例文,谷歌搜索引擎免费入口2022个人理解#xff0c;可能有误#xff0c;仅供参考
LSO: LastStableOffset#xff0c;分区中第一个未完成事务的起始偏移量#xff0c;或如果没有未完成事务则为HW。
LSO HW LEO
LSO起作用必须满足以下所有条件:
同一个分区多个生产者[也可以只有一个]中必须至少有…个人理解可能有误仅供参考LSO: LastStableOffset分区中第一个未完成事务的起始偏移量或如果没有未完成事务则为HW。LSO HW LEOLSO起作用必须满足以下所有条件:同一个分区多个生产者[也可以只有一个]中必须至少有一个是事务生产者该分区的消费者isolation.level参数值必须为read_committed在 isolation.levelread_committed 模式下消费者只能读取到 LSO 之前的消息如果事务未提交LSO 会停留在第一个未提交事务的起始偏移量这意味着LSO 之后的所有消息无论事务/非事务都无法被读取直到生产者事务提交事务消费者才能继续消费后边的消息示例有两个生产者将消息发往同一分区一个是事务生产者一个是非事务生产者该分区的消费者设置参数isolation.levelread_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全部可见