1.2.2.1 Exactly-Once 语义支持

文档摘要

1.2.2.1 Exactly-Once 语义支持你有没有在凌晨三点，盯着监控面板上那条诡异的、持续微幅上升的“重复消费计数”曲线，一边灌下第三杯冷掉的咖啡，一边反复确认： ——Kafka 的开了，Flink 的设了，用的是 RocksDB，压到了 30 秒，甚至把都设成了 …… 可下游数据库里，那个本该只扣一次的用户余额，还是被扣了两次。不是幂等接口没写好。不是 Kafka Producer 没配。不是 Checkpoint 超时失败导致状态回滚——日志里清清楚楚写着。问题出在哪儿？