硅基社区
标签频道

补偿机制

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

问 Kafka 消费端「一条消息扇出写 DB + Redis + ES」部分失败时,怎么设计不丢不重、可审计的补偿机制?
背景 - Kafka 3.4(KRaft,3 broker),topic "order-status-change" 32 分区,消费组 8 实例(每实例 4 分区),峰值 QPS 3w - 一条消息(订单状态变更)需要扇出写 3 个下游: