标签 · read_committed

问 read_committed 消费端被 aborted 事务卡住的「悬挂窗口」：producer 在 commit 与 commitResponse 之间 kill -9，LSO 推进要等 transaction.timeout 多久才能提前发现并自愈？

背景 Kafka 3.5（KRaft，3 broker，ISR=3），topic "order-fulfill" 16 分区，生产端 8 实例用事务 producer（"enable.idempotence=true" + "transac

作者江星河-785 · 赞 0 · 评 0 · 2026-10-26T11:12:13.134

文 Kafka 事务的原子性边界是 PID epoch 不是进程：双 producer 共用 transactional.id 后 1.8 万条消息静默失败，而 read_committed 反而放行了脏数据

«栈：Kafka 3.5.2（KRaft，3 broker，8C32G）、Spring Kafka 3.1.5、kafka-clients 3.5.2、Java 17（G1）、MySQL 8.0.36 一句话结论：Kafka 事务的原子性边

作者江星河 · 赞 0 · 评 0 · 2026-10-22T07:42:16.130

问 read_committed 消费端被 aborted 事务卡住的「悬挂窗口」：producer 在 commit 与 commitResponse 之间 kill -9，LSO 推进要等 transaction.timeout 多久才能提前发现并自愈？

背景 Kafka 3.5（KRaft，3 broker，ISR=3），topic "order-fulfill" 16 分区，生产端 8 实例用事务 producer（"enable.idempotence=true" + "transac

作者江星河-785 · 赞 0 · 评 0 · 2026-10-20T00:05:36.632

文 Kafka 事务的 PID+epoch 围栏与 transaction.timeout.ms 的真实窗口：一次 47s GC 引发的 UnknownProducerFenceException 复盘

«作者：江星河-385｜15 年全栈｜分布式一致性与消息中间件方向栈：Kafka 3.5.1（KRaft，3 broker，8C32G）、Spring Kafka 3.1.5、Java 17（G1 GC）、MySQL 8.0.36 场景：

作者江星河-385 · 赞 4 · 评 2 · 2026-10-17T14:23:14.853

文 Kafka read_uncommitted 与 read_committed 混跑：一次 offset 错位导致的 40 分钟数据丢失复盘

一、现象与背景：消费端没报错，但下游对不上账先给结论：在同一个 topic 上，read_uncommitted 和 read_committed 两个消费组"看到的 offset 根本不是同一把尺子"，一旦你在两者之间做迁移、重放或 o

作者江望舒-235 · 赞 0 · 评 0 · 2026-10-14T03:30:57.706

文 Kafka read_committed 消费端被悬挂事务卡 90 秒：LSO/LEO 语义与定位命令全记录

一、现象与背景：消费端不是慢，是「停摆」去年我们做支付对账链路，Kafka 3.5（3 节点 KRaft），"pay-settle" topic 16 分区、峰值约 6.2 万 msg/s，消费组 4 实例，"isolation.leve

作者江景行-145 · 赞 4 · 评 0 · 2026-10-14T00:30:12.496