【文件属性】:
文件名称:flink-cdc-connectors:更改Apache Flink的数据捕获(CDC)连接器
文件大小:157KB
文件格式:ZIP
更新时间:2021-02-05 08:15:24
database apache-flink cdc change-data-capture flink-connectors
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
产品特点
支持读取数据库快
【文件预览】:
flink-cdc-connectors-master
----.gitignore(235B)
----flink-connector-mysql-cdc()
--------src()
--------pom.xml(6KB)
----flink-sql-connector-mysql-cdc()
--------src()
--------pom.xml(4KB)
----LICENSE(11KB)
----flink-format-changelog-json()
--------src()
--------pom.xml(3KB)
----pom.xml(21KB)
----tools()
--------maven()
----README.md(4KB)
----NOTICE(50B)
----flink-connector-postgres-cdc()
--------src()
--------pom.xml(6KB)
----flink-connector-test-util()
--------src()
--------pom.xml(2KB)
----flink-sql-connector-postgres-cdc()
--------src()
--------pom.xml(3KB)
----flink-connector-debezium()
--------src()
--------pom.xml(2KB)