Debezium系列之：Flink SQL消费Debezium数据格式，同步数据到下游存储系统
一、Debezium
Debezium 是一个 CDC（Changelog Data Capture，变更数据捕获）的工具，可以把来自 MySQL、PostgreSQL、Oracle、Microsoft SQL Server 和许多其他数据库的更改实时流式传输到 Kafka 中。 Debezium 为变更日志提供了统一的格式结构，并支持使用 JSON 和 Apache Avro 序列化消息。
Flink 支持将 Debezium JSON 和 Avro 消息解析为 INSERT / UPDATE / DELETE 消息到 Flink SQL 系统中。在很
本文转载自: https://blog.csdn.net/zhengzaifeidelushang/article/details/135132274
版权归原作者 最笨的羊羊 所有， 如有侵权，请联系我们删除。
版权归原作者 最笨的羊羊 所有， 如有侵权，请联系我们删除。