幂等性

Question

在这个项目中如何实现的 幂等性？在cdc 设置的吗？

Answer 1

Michael_PK 2023-08-07 22:45:50

要实现一次性语义，对应sink来说最常使用的就是幂等性以及两阶段提交。

幂等性，比如说你是sink到mysql等数据库，其实要的就是upsert的功能，能对数据进行更新。其实就是on duplicate  key update的语义。当然mysql也是可以使用两阶段提交语义来实现的，只不过要自己自定义实现。

cdc的一致性实现可以参考这个文章：https://rank.chinaz.comapi.dandelioncloud.cn/article/details/1579641570817437698