debezium官方分布式事务Saga案例源码


此示例演示如何使用变更数据捕获以安全可靠的方式实现Saga 模式,以实现跨多个微服务的分布式事务。
基于发件箱模式,此实现避免了对服务数据库和 Apache Kafka 的不安全双重写入,方法是通过原始服务的数据库引导所有传出消息,并使用 CDC 和 Debezium 从那里捕获它们。
涉及三个服务:

  • order-service: Saga 的发起者和协调者
  • 客户服务:验证传入订单是否在客户的信用额度内,并相应地批准或拒绝
  • 付款服务执行与传入订单关联的付款

点击标题