标签频道
事务
该标签下的文章、提问与讨论帖。
【背景】 我们团队在做订单履约链路时，遇到了一个关键问题：如何在 Kafka 中实现 exactly-once 的消息处理，同时保证业务的幂等性。我们尝试了 Kafka 事务和 Outbox 两种方案，但发现它们各有优劣，且边界模糊。 【常
现象或背景 在 Kafka 消费端，幂等去重是保障消息不重复处理的关键。我们遇到了一个典型问题：在同一个 InnoDB 事务中写入幂等表与业务表，和两个独立事务（先写幂等表，后写业务表）之间，哪种更容易产生「幂等假阳性」？即幂等记录存在，但
【背景】 在 Kafka 的事务性消费者场景中，我们遇到一个异常 Rebalance 的情况：旧实例在 Rebalance 前提交了 commitTransaction，但因某些原因延迟了 offset 的提交。与此同时，新实例在 Reba
背景 我负责一条订单域链路，Kafka 3.5.2（KRaft，3 controller 节点，broker 8 台 16C64G），生产端 8 实例用事务 producer（"enable.idempotence=true" + "tra
«作者：江景行-145｜8 年全栈｜分布式一致性与消息中间件方向 栈：Kafka 3.5.1（KRaft，3 broker，8C32G）、Spring Kafka 3.1.5、Java 17（G1）、MySQL 8.0.36、K8s 1.2
«栈：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 事务的原子性边
背景 我负责一条支付回调链路，Kafka 3.5（KRaft，3 broker），topic "payment-callback" 16 分区，消费组 4 实例。消费端用 Kafka 事务（"isolation.level=read_com
文
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 场景：
«作者：江寒山-975｜10 年技术团队负责人｜分布式一致性与消息中间件方向 栈：Kafka 3.5.2（KRaft，3 broker）、Spring Kafka 3.1.5、Java 17、MySQL 8.0.36 兜底 场景：订单域，一
【背景】 我用 gRPC-Go v1.62 + Go 1.21 提供一个 client-streaming 接口：客户端分批 send 一批「明细行」（约 200~2000 行），CloseSend 后服务端才开始真正处理——逐行校验 →
【背景】 Spring Boot 3.2 + JDK 17 + MySQL 8.0 + HikariCP 5.1，池大小 20，connectionTimeout=3000ms，minimumIdle=5，maxLifetime=1800s
【背景】 订单履约链路，Kafka 3.5（3 broker，KRaft）。事务生产者：enable.idempotence=true，transactional.id=order-fulfil-{instance}，同一个事务内顺序写三个
文
标题
摘要