@@ -3,7 +3,7 @@ title: "概览"
33weight : 1
44type : docs
55aliases :
6- - /connectors/legacy- flink-cdc -sources/
6+ - /connectors/flink-sources/
77---
88<!--
99Licensed to the Apache Software Foundation (ASF) under one
@@ -24,28 +24,28 @@ specific language governing permissions and limitations
2424under the License.
2525-->
2626
27- # Legacy CDC sources
27+ # Flink Sources 连接器
2828
29- Legacy CDC sources is a set of source connectors for <a href =" https://flink.apache.org/ " >Apache Flink<sup >®</sup ></a >, ingesting changes from different databases using change data capture (CDC).
29+ Flink CDC sources is a set of source connectors for <a href =" https://flink.apache.org/ " >Apache Flink<sup >®</sup ></a >, ingesting changes from different databases using change data capture (CDC).
3030Some CDC sources integrate Debezium as the engine to capture data changes. So it can fully leverage the ability of Debezium. See more about what is [ Debezium] ( https://github.com/debezium/debezium ) .
3131
32- You can also read [ tutorials] ({{< ref "docs/connectors/legacy- flink-cdc -sources/tutorials/build-streaming-etl-tutorial" >}}) about how to use these sources.
32+ You can also read [ tutorials] ({{< ref "docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial" >}}) about how to use these sources.
3333
3434{{< img src="/fig/cdc-flow.png" width="600px" alt="Flink CDC" >}}
3535
3636## Supported Connectors
3737
3838| Connector | Database | Driver |
3939| ---------------------------------------------------------------------------------------| --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| ---------------------------|
40- | [ mongodb-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/mongodb-cdc" >}}) | <li > [ MongoDB] ( https://www.mongodb.com ) : 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 |
41- | [ mysql-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/mysql-cdc" >}}) | <li > [ MySQL] ( https://dev.mysql.com/doc ) : 5.6, 5.7, 8.0.x <li > [ RDS MySQL] ( https://www.aliyun.com/product/rds/mysql ) : 5.6, 5.7, 8.0.x <li > [ PolarDB MySQL] ( https://www.aliyun.com/product/polardb ) : 5.6, 5.7, 8.0.x <li > [ Aurora MySQL] ( https://aws.amazon.com/cn/rds/aurora ) : 5.6, 5.7, 8.0.x <li > [ MariaDB] ( https://mariadb.org ) : 10.x <li > [ PolarDB X] ( https://github.com/ApsaraDB/galaxysql ) : 2.0.1 | JDBC Driver: 8.0.28 |
42- | [ oceanbase-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/oceanbase-cdc" >}}) | <li > [ OceanBase CE] ( https://open.oceanbase.com ) : 3.1.x, 4.x <li > [ OceanBase EE] ( https://www.oceanbase.com/product/oceanbase ) : 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x |
43- | [ oracle-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/oracle-cdc" >}}) | <li > [ Oracle] ( https://www.oracle.com/index.html ) : 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 |
44- | [ postgres-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/postgres-cdc" >}}) | <li > [ PostgreSQL] ( https://www.postgresql.org ) : 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 |
45- | [ sqlserver-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/sqlserver-cdc" >}}) | <li > [ Sqlserver] ( https://www.microsoft.com/sql-server ) : 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 |
46- | [ tidb-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/tidb-cdc" >}}) | <li > [ TiDB] ( https://www.pingcap.com/ ) : 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0 | JDBC Driver: 8.0.27 |
47- | [ db2-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/db2-cdc" >}}) | <li > [ Db2] ( https://www.ibm.com/products/db2 ) : 11.5 | Db2 Driver: 11.5.0.0 |
48- | [ vitess-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/vitess-cdc" >}}) | <li > [ Vitess] ( https://vitess.io/ ) : 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 |
40+ | [ mongodb-cdc] ({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) | <li > [ MongoDB] ( https://www.mongodb.com ) : 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 |
41+ | [ mysql-cdc] ({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) | <li > [ MySQL] ( https://dev.mysql.com/doc ) : 5.6, 5.7, 8.0.x <li > [ RDS MySQL] ( https://www.aliyun.com/product/rds/mysql ) : 5.6, 5.7, 8.0.x <li > [ PolarDB MySQL] ( https://www.aliyun.com/product/polardb ) : 5.6, 5.7, 8.0.x <li > [ Aurora MySQL] ( https://aws.amazon.com/cn/rds/aurora ) : 5.6, 5.7, 8.0.x <li > [ MariaDB] ( https://mariadb.org ) : 10.x <li > [ PolarDB X] ( https://github.com/ApsaraDB/galaxysql ) : 2.0.1 | JDBC Driver: 8.0.28 |
42+ | [ oceanbase-cdc] ({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) | <li > [ OceanBase CE] ( https://open.oceanbase.com ) : 3.1.x, 4.x <li > [ OceanBase EE] ( https://www.oceanbase.com/product/oceanbase ) : 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x |
43+ | [ oracle-cdc] ({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) | <li > [ Oracle] ( https://www.oracle.com/index.html ) : 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 |
44+ | [ postgres-cdc] ({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) | <li > [ PostgreSQL] ( https://www.postgresql.org ) : 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 |
45+ | [ sqlserver-cdc] ({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) | <li > [ Sqlserver] ( https://www.microsoft.com/sql-server ) : 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 |
46+ | [ tidb-cdc] ({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) | <li > [ TiDB] ( https://www.pingcap.com/ ) : 5.1.x, 5.2.x, 5.3.x, 5.4.x, 6.0.0 | JDBC Driver: 8.0.27 |
47+ | [ db2-cdc] ({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) | <li > [ Db2] ( https://www.ibm.com/products/db2 ) : 11.5 | Db2 Driver: 11.5.0.0 |
48+ | [ vitess-cdc] ({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) | <li > [ Vitess] ( https://vitess.io/ ) : 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 |
4949
5050## Supported Flink Versions
5151The following table shows the version mapping between Flink<sup >®</sup > CDC Connectors and Flink<sup >®</sup >:
@@ -74,15 +74,15 @@ The following table shows the current features of the connector:
7474
7575| Connector | No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read |
7676| ---------------------------------------------------------------------------------------| --------------| ---------------| -------------------| ---------------------------|
77- | [ mongodb-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/mongodb-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
78- | [ mysql-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/mysql-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
79- | [ oracle-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/oracle-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
80- | [ postgres-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/postgres-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
81- | [ sqlserver-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/sqlserver-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
82- | [ oceanbase-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/oceanbase-cdc" >}}) | ❌ | ❌ | ❌ | ❌ |
83- | [ tidb-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/tidb-cdc" >}}) | ✅ | ❌ | ✅ | ❌ |
84- | [ db2-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/db2-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
85- | [ vitess-cdc] ({{< ref "docs/connectors/legacy- flink-cdc -sources/vitess-cdc" >}}) | ✅ | ❌ | ✅ | ❌ |
77+ | [ mongodb-cdc] ({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
78+ | [ mysql-cdc] ({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
79+ | [ oracle-cdc] ({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
80+ | [ postgres-cdc] ({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
81+ | [ sqlserver-cdc] ({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
82+ | [ oceanbase-cdc] ({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) | ❌ | ❌ | ❌ | ❌ |
83+ | [ tidb-cdc] ({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) | ✅ | ❌ | ✅ | ❌ |
84+ | [ db2-cdc] ({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) | ✅ | ✅ | ✅ | ✅ |
85+ | [ vitess-cdc] ({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) | ✅ | ❌ | ✅ | ❌ |
8686
8787## Usage for Table/SQL API
8888
0 commit comments