Flink-connector-debezium 基于Red Hat开源的Debezium组件,和Flink结合,实现在Flink上直接监听各种数据库的Change Log,并且能够利用Flink的特性,输出到不同的位置上,以实现数据总线和实时数仓的构建。此项目主要应用于数据中台或数据平台中数据总线的基础底座。 目前Debezium支持了MySQL、MongoDB、PostgreSQL、Oracle、SQL Server、Db2和Cassandra。理论上此连接器也支援以上所有数据库。 Getting Started mvn clean package -DskipTests example 参考DebeziumSourceITCase
2021-09-17 01:50:43 20KB flink change-data-capture debezium Java
1
Flink CDC连接器 Flink CDC连接器是Apache Flink的一组源连接器,使用更改数据捕获(CDC)从不同的数据库中提取更改。 Flink CDC连接器将Debezium集成为引擎来捕获数据更改。 因此,它可以充分利用Debezium的功能。 进一步了解什么是 。 本自述文件旨在简要介绍Flink CDC连接器的核心功能。 有关详细文档,请参阅。 支持(经过测试)的连接器 数据库 版 MySQL 数据库:5.7,8.0.x JDBC驱动程序:8.0.16 PostgreSQL 数据库:9.6,10,11,12 JDBC驱动程序:42.2.12 产品特点 支持读取数据库快
2021-06-20 23:21:20 157KB database apache-flink cdc change-data-capture
1