flink实战--CDC (Change Data Capture )终极总结_flink cdc 捕获修改表结构变更

作者：Monodyee | 2024-04-29 13:51:43

踩

flink cdc 捕获修改表结构变更

CDC简介

CDC - Change Data Capture,变更数据获取的简称，用于从数据库中捕获已提交的更改并将这些更改按照真实发生的顺序传播到下游使用者。这些变更可以包括INSERT,DELETE,UPDATE等.在Flink中，能够轻松地将这些变更日志提取并解释为Table API / SQL的功能是Flink社区中非常需要的功能-现在Flink 1.11可以实现这一功能。

为了将Table API / SQL的范围扩展到CDC之类的用例，Flink 1.11引入了具有changelog模式的新表源和接收器接口（请参见New TableSource和TableSink接口），并支持Debezium和Canal格式。这意味着动态表源不再仅限于附加的操作和可以摄取这些外部更改日志（INSERT事件），将它们解释为改变操作（INSERT，UPD

声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：【wpsshop博客】