标签频道
Outbox
该标签下的文章、提问与讨论帖。
【背景】 在 Kafka 的 exactly-once 实践中，我们常常面临一个关键问题：究竟应该在消息生产端使用 Outbox + 业务幂等，还是在全链路使用事务来保证一致性？ 【常见分歧】 - Outbox + 业务幂等： - 优点：实
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
【背景】 我们去年在做订单履约链路，使用 Kafka 3.5（KRaft，3 broker），核心路径是：订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。最初我们尝试使用 Kafka 事务（enable
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
Kafka 消费幂等设计：业务主键 vs 消息 ID vs traceId 的取舍与边界 一、现象或背景 在 Kafka 消费场景中，幂等设计是避免重复消费、保障数据一致性的重要手段。然而，如何选择幂等键（idempotent key）是实
【背景】 在分布式系统中，数据一致性是一个永恒的挑战。我们经常需要在多个服务之间进行数据同步，确保数据的最终一致性。目前，有两种主流的解决方案：Outbox 模式和全链路事务。 【常见分歧】 1. Outbox 模式： - 优点：实现简单，
【背景】 在 Kafka 消费端实现 Exactly-Once 保证时，我们团队曾陷入长达半年的争论：是采用 Outbox 模式 + 业务幂等，还是全链路事务？ 【常见分歧】 - Outbox 派：认为事务消息是 Kafka 的原生能力（i
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
【背景】 我们团队在做订单履约链路时，遇到了一个关键问题：如何在 Kafka 中实现 exactly-once 的消息处理，同时保证业务的幂等性。我们尝试了 Kafka 事务和 Outbox 两种方案，但发现它们各有优劣，且边界模糊。 【常
【背景】 在高并发系统中，Kafka 的 exactly-once 保证是一个常见的挑战。我们近期在处理一个订单履约链路时，遇到了 Kafka 事务与业务幂等之间的取舍问题。这个系统包括订单创建、写 MySQL、发 Kafka 消息以及消费
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
【背景】 在一次订单履约链路中，我们使用 Kafka 3.5（KRaft，3 broker）进行异步通知。核心路径是：订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。最初我们尝试使用 Kafka 事务（
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
【背景】 在 Kafka 的消息传递中，exactly-once 是一个常见的需求，但它的实现边界却常常存在争议。我们团队在实现一个订单履约链路时，曾遇到 Kafka 的 exactly-once 需求，最终选择了 Outbox + 业务幂
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。 最初用 Kafka 事务（enable.idempot
背景 社区对 outbox 表 + CDC 的选型已经讨论得比较透了（见下方引用），我这边已经落地了 outbox + Debezium + Kafka Connect 方案，但踩了一个隐蔽的坑：outbox 表本身的生命周期操作（状态流转
【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径：订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。最初用 Kafka 事务（enable.idempoten
【背景】 去年我们做订单履约链路时，Kafka 3.5（KRaft，3 broker），核心路径：订单创建 → 写 MySQL → 发 Kafka 消息 → 消费者调外部物流 API。最初用 Kafka 事务（enable.idempote
【背景】 订单履约链路：业务服务（K8s，4 副本）→ Kafka 3.5（3 broker，KRaft，"acks=all"，"min.insync.replicas=2"）→ 消费端写 MySQL 8.0 业务表。生产端配置："enab
【背景】 先讲我踩过的一个坑。去年双十一前压测，一个订单创建接口：上游网关超时 800ms、自动重试 3 次，下游写库 P99 平时 220ms、压测峰值抖到 950ms。结果 10 分钟窗口内，同一个订单号在库里出现了最多 3 条记录。事
已经到底了
文
标题
摘要