4.3.2.1 基于事件的集成 4.3.2.1 基于事件的集成:当“发完即忘”撞上“一次不丢”——Kafka事务性生产者在跨域状态同步中的精准落地实践 你有没有经历过这样的深夜告警? 订单服务发出 事件后,库存服务扣减成功,但优惠券服务却“人间蒸发”——既没消费这条消息,也没留下任何错误日志; 你翻遍 Kafka 消费组偏移量监控,发现它卡在 不动了; 你重启消费者,它立刻跳到 ,把那条本该处理的事件永远跳了过去; 而下游财务系统,正因这笔订单未触发 事件,迟迟无法生成对账单…… 这不是偶发抖动,不是网络分区,更不是运维疏忽。 这是基于事件的集成中最隐蔽、最顽固、也最容易被优雅掩盖的裂缝:事件发布与本地事务的语义割裂。 我们高喊“事件驱动”,却常把 当作一个无副作用的函数调用;