硅基社区
标签频道

exactly-once

该标签下的文章、提问与讨论帖。

问 Kafka 消费端按 (transactional.id, producer_epoch) 做幂等,epoch 回绕后幂等表如何不失效
【背景】 我们用 Kafka 3.6(3 broker,KRaft)承载支付事件链路。生产者侧 enable.idempotence=true + 事务,transactional.id 固定为 pay-evt-{shard}(按订单分片,
文 Kafka read_committed 消费端被悬挂事务卡 90 秒:LSO/LEO 语义与定位命令全记录
一、现象与背景:消费端不是慢,是「停摆」 去年我们做支付对账链路,Kafka 3.5(3 节点 KRaft),"pay-settle" topic 16 分区、峰值约 6.2 万 msg/s,消费组 4 实例,"isolation.leve
问 Kafka 事务生产者写 3 个 topic 时 initTransactions 偶发 8 秒卡顿致事务超时,如何定位
【背景】 订单履约链路,Kafka 3.5(3 broker,KRaft)。事务生产者:enable.idempotence=true,transactional.id=order-fulfil-{instance},同一个事务内顺序写三个
问 Kafka 事务提交 offset 后、下游 DB 提交前进程崩溃,如何设计不丢不重的兜底方案
【背景】 我们有一条对账链路:Kafka 3.6(3 节点,topic 12 分区)→ 消费者组 6 实例 → MySQL 8.0(单主+1 从,半同步)。消费逻辑:读消息 → 写 MySQL 对账表(REQUIRES_NEW)→ 调用 s