outbox-pattern-implementation

当需要以原子方式将消息发布到 Kafka / RabbitMQ / SNS 并同时提交数据库事务时，用于解决数据库与消息代理之间的双写问题；在轮询发布器（polling-publisher）与变更数据捕获（CDC，如 Debezium）中继之间进行选择时；设计发件箱（outbox）表结构时；处理消费者端的至少一次投递（at-least-once）与幂等性时；或对高吞吐量的发件箱表进行清理时。 触发场景包括：双写问题、“我们更新了数据库但事件从未发布”、发件箱/收件箱模式、Debezium 连接器、EventRouter SMT、聚合类型（aggregate_type）/聚合 ID（aggregate_id）、至少一次投递配合幂等消费者、发件箱表分区等。 不适用于接收端 Webhook 处理、使用 Saga 或 Temporal 进行流程编排、以日志为基础的事件溯源作为事实来源，或一般的 Kafka 生产者调优。

存档时间线

版本索引永久保留；内容副本只保留最新 1 份，更早版本仅留索引与哈希（存档时间线的证据链不会因此断裂）。

下载存档内容副本