From 8098a9ca3e847a8f8ee2f46b37e19d124a22617a Mon Sep 17 00:00:00 2001 From: Hongshun Wang <125648852+loserwang1024@users.noreply.github.com> Date: Tue, 19 Mar 2024 16:48:39 +0800 Subject: [PATCH] [FLINK-34724][docs] Fix broken web link in document of legacy Flink CDC Sources (#3167) --- docs/config.toml | 2 +- .../legacy-flink-cdc-sources/db2-cdc.md | 7 +- .../legacy-flink-cdc-sources/mongodb-cdc.md | 4 +- .../legacy-flink-cdc-sources/mysql-cdc.md | 8 +-- .../legacy-flink-cdc-sources/oceanbase-cdc.md | 2 +- .../legacy-flink-cdc-sources/oracle-cdc.md | 2 +- .../legacy-flink-cdc-sources/overview.md | 64 ++++++++++++------- .../legacy-flink-cdc-sources/postgres-cdc.md | 2 +- .../legacy-flink-cdc-sources/sqlserver-cdc.md | 2 +- .../legacy-flink-cdc-sources/tidb-cdc.md | 2 +- .../legacy-flink-cdc-sources/vitess-cdc.md | 4 ++ .../legacy-flink-cdc-sources/db2-cdc.md | 7 +- .../legacy-flink-cdc-sources/mongodb-cdc.md | 2 +- .../legacy-flink-cdc-sources/mysql-cdc.md | 8 +-- .../legacy-flink-cdc-sources/oceanbase-cdc.md | 2 +- .../legacy-flink-cdc-sources/oracle-cdc.md | 2 +- .../legacy-flink-cdc-sources/overview.md | 57 +++++++++++------ .../legacy-flink-cdc-sources/postgres-cdc.md | 2 +- .../legacy-flink-cdc-sources/sqlserver-cdc.md | 2 +- .../legacy-flink-cdc-sources/tidb-cdc.md | 2 +- .../legacy-flink-cdc-sources/vitess-cdc.md | 4 ++ 21 files changed, 112 insertions(+), 75 deletions(-) diff --git a/docs/config.toml b/docs/config.toml index 44a5b3310..9882c4bf1 100644 --- a/docs/config.toml +++ b/docs/config.toml @@ -58,7 +58,7 @@ pygmentsUseClasses = true ] PreviousDocs = [ - ["3.0", "https://nightlies.apache.org/flink-cdc/flink-cdc-docs-release-3.0"], + ["3.0", "https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0"], ] [markup] diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md index b662b5c9d..346dd1450 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md @@ -34,7 +34,7 @@ describes how to setup the db2 CDC connector to run SQL queries against Db2 data | Connector | Database | Driver | |-----------------------|----------------------------------------------------|----------------------| -| [Db2-cdc](db2-cdc.md) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | +| [Db2-cdc](../db2-cdc) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | Dependencies ------------ @@ -53,9 +53,8 @@ using a build automation tool (such as Maven or SBT) and SQL Client with SQL JAR Download flink-sql-connector-db2-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-db2-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users -need to download the source code and compile the corresponding jar. Users should use the released version, such as -[flink-sql-connector-db2-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-db2-cdc), +**Note:** flink-sql-connector-db2-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as +[flink-sql-connector-db2-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-db2-cdc), the released version will be available in the Maven central warehouse. Setup Db2 server diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md index 4525fee67..e13afa7c2 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md @@ -43,7 +43,7 @@ In order to setup the MongoDB CDC connector, the following table provides depend Download [flink-sql-connector-mongodb-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.0-SNAPSHOT/flink-sql-connector-mongodb-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-mongodb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mongodb-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-mongodb-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-mongodb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mongodb-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-mongodb-cdc), the released version will be available in the Maven central warehouse. Setup MongoDB ---------------- @@ -52,7 +52,7 @@ Setup MongoDB - MongoDB version MongoDB version >= 3.6
    -We use [change streams](https://docs.mongodb.com/manual/changeStreams/) feature (new in version 3.6) to capture change data. + We use [change streams](https://docs.mongodb.com/manual/changeStreams/) feature (new in version 3.6) to capture change data. - Cluster Deployment diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md index ea75c17ab..50d148ca7 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md @@ -31,9 +31,9 @@ The MySQL CDC connector allows for reading snapshot data and incremental data fr ## Supported Databases -| Connector | Database | Driver | -|-----------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------| -| [mysql-cdc](mysql-cdc.md) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.27 | +| Connector | Database | Driver | +|---------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------| +| [mysql-cdc](../mysql-cdc) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.27 | Dependencies ------------ @@ -50,7 +50,7 @@ In order to setup the MySQL CDC connector, the following table provides dependen Download flink-sql-connector-mysql-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-mysql-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mysql-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-mysql-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-mysql-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-mysql-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-mysql-cdc), the released version will be available in the Maven central warehouse. Setup MySQL server ---------------- diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md index 57b6bc97e..f1767049e 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md @@ -51,7 +51,7 @@ If you want to use OceanBase JDBC driver to connect to the enterprise edition da Download [flink-sql-connector-oceanbase-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.0-SNAPSHOT/flink-sql-connector-oceanbase-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-oceanbase-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oceanbase-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oceanbase-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-oceanbase-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oceanbase-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-oceanbase-cdc), the released version will be available in the Maven central warehouse. For JDBC driver, the cdc jar above already contains MySQL JDBC driver 5.1.47, which is our recommended version. Due to the license issue, we can not include the OceanBase JDBC driver in the cdc jar. If you need to use it, you can download it from [here](https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/2.4.2/oceanbase-client-2.4.2.jar) and put it under `/lib/`, you also need to set the start option `jdbc.driver` to `com.oceanbase.jdbc.Driver`. diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md index 9c4bab2b9..36e78e4bd 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md @@ -43,7 +43,7 @@ In order to setup the Oracle CDC connector, the following table provides depende Download [flink-sql-connector-oracle-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.0-SNAPSHOT/flink-sql-connector-oracle-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-oracle-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oracle-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oracle-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-oracle-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oracle-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-oracle-cdc), the released version will be available in the Maven central warehouse. Setup Oracle ---------------- diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md index babdb7931..842d15c96 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md @@ -24,10 +24,11 @@ specific language governing permissions and limitations under the License. --> -# CDC Connectors for Apache Flink +# Legacy CDC sources for Apache Flink + +Flink CDC sources is a set of source connectors for Apache Flink®, ingesting changes from different databases using change data capture (CDC). +Some 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). -CDC Connectors for Apache Flink® is a set of source connectors for Apache Flink®, ingesting changes from different databases using change data capture (CDC). -The CDC Connectors for Apache Flink® 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). {{< img src="/fig/cdc-flow.png" width="600px" alt="Flink CDC" >}} @@ -35,15 +36,15 @@ The CDC Connectors for Apache Flink® integrate Debezium as the engin | Connector | Database | Driver | |-----------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------| -| [mongodb-cdc](mongodb-cdc.md) |
  • [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 | -| [mysql-cdc](mysql-cdc.md) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 | -| [oceanbase-cdc](oceanbase-cdc.md) |
  • [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x
  • [OceanBase EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x | -| [oracle-cdc](oracle-cdc.md) |
  • [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 | -| [postgres-cdc](postgres-cdc.md) |
  • [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 | -| [sqlserver-cdc](sqlserver-cdc.md) |
  • [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 | -| [tidb-cdc](tidb-cdc.md) |
  • [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 | -| [db2-cdc](db2-cdc.md) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | -| [vitess-cdc](vitess-cdc.md) |
  • [Vitess](https://vitess.io/): 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 | +| [mongodb-cdc](../mongodb-cdc) |
  • [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 | +| [mysql-cdc](../mysql-cdc) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 | +| [oceanbase-cdc](../oceanbase-cdc) |
  • [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x
  • [OceanBase EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x | +| [oracle-cdc](../oracle-cdc) |
  • [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 | +| [postgres-cdc](../postgres-cdc) |
  • [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 | +| [sqlserver-cdc](../sqlserver-cdc) |
  • [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 | +| [tidb-cdc](../tidb-cdc) |
  • [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 | +| [db2-cdc](../db2-cdc) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | +| [vitess-cdc](../vitess-cdc) |
  • [Vitess](https://vitess.io/): 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 | ## Supported Flink Versions The following table shows the version mapping between Flink® CDC Connectors and Flink®: @@ -70,24 +71,24 @@ The following table shows the version mapping between Flink® CDC Con The following table shows the current features of the connector: -| Connector | No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read | -|-----------------------------------|--------------|---------------|-------------------|---------------------------| -| [mongodb-cdc](mongodb-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [mysql-cdc](mysql-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [oracle-cdc](oracle-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [postgres-cdc](postgres-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [sqlserver-cdc](sqlserver-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [oceanbase-cdc](oceanbase-cdc.md) | ❌ | ❌ | ❌ | ❌ | -| [tidb-cdc](tidb-cdc.md) | ✅ | ❌ | ✅ | ❌ | -| [db2-cdc](db2-cdc.md) | ❌ | ❌ | ✅ | ❌ | -| [vitess-cdc](vitess-cdc.md) | ✅ | ❌ | ✅ | ❌ | +| Connector | No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read | +|--------------------------------|--------------|---------------|-------------------|---------------------------| +| [mongodb-cdc](../mongodb-cdc) | ✅ | ✅ | ✅ | ✅ | +| [mysql-cdc](../mysql-cdc) | ✅ | ✅ | ✅ | ✅ | +| [oracle-cdc](../oracle-cdc) | ✅ | ✅ | ✅ | ✅ | +| [postgres-cdc](../postgres-cdc) | ✅ | ✅ | ✅ | ✅ | +| [sqlserver-cdc](../sqlserver-cdc) | ✅ | ✅ | ✅ | ✅ | +| [oceanbase-cdc](../oceanbase-cdc) | ❌ | ❌ | ❌ | ❌ | +| [tidb-cdc](../tidb-cdc) | ✅ | ❌ | ✅ | ❌ | +| [db2-cdc](../db2-cdc) | ❌ | ❌ | ✅ | ❌ | +| [vitess-cdc](../vitess-cdc) | ✅ | ❌ | ✅ | ❌ | ## Usage for Table/SQL API We need several steps to setup a Flink cluster with the provided connector. 1. Setup a Flink cluster with version 1.12+ and Java 8+ installed. -2. Download the connector SQL jars from the [Downloads](../downloads.md) page (or [build yourself](#building-from-source)). +2. Download the connector SQL jars from the [Downloads](https://github.com/apache/flink-cdc/releases) page (or [build yourself](#building-from-source)). 3. Put the downloaded jars under `FLINK_HOME/lib/`. 4. Restart the Flink cluster. @@ -304,4 +305,19 @@ you can construct `JsonDebeziumDeserializationSchema` as following: new JsonDebeziumDeserializationSchema(true, customConverterConfigs); ``` +## Building from source + +Prerequisites: +- git +- Maven +- At least Java 8 + +``` +git clone https://github.com/apache/flink-cdc.git +cd flink-cdc +mvn clean install -DskipTests +``` + +The dependencies are now available in your local `.m2` repository. + {{< top >}} diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md index 63f3f14d1..cfb7ab9c7 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md @@ -43,7 +43,7 @@ In order to setup the Postgres CDC connector, the following table provides depen Download flink-sql-connector-postgres-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-postgres-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-postgres-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-postgres-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-postgres-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-postgres-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-postgres-cdc), the released version will be available in the Maven central warehouse. How to create a Postgres CDC table ---------------- diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md index 799b5de48..f4f342c1a 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md @@ -43,7 +43,7 @@ In order to setup the SQLServer CDC connector, the following table provides depe Download [flink-sql-connector-sqlserver-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.0-SNAPSHOT/flink-sql-connector-sqlserver-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-sqlserver-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-sqlserver-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-sqlserver-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-sqlserver-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-sqlserver-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-sqlserver-cdc), the released version will be available in the Maven central warehouse. Setup SQLServer Database ---------------- diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md index 982ad4116..1348ba381 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md @@ -43,7 +43,7 @@ In order to setup the TiDB CDC connector, the following table provides dependenc Download [flink-sql-connector-tidb-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.0-SNAPSHOT/flink-sql-connector-tidb-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-tidb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-tidb-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-tidb-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-tidb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-tidb-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-tidb-cdc), the released version will be available in the Maven central warehouse. How to create a TiDB CDC table ---------------- diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md index 9a0919735..0f56654fa 100644 --- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md +++ b/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md @@ -42,6 +42,10 @@ In order to setup the Vitess CDC connector, the following table provides depende Download [flink-sql-connector-vitess-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-vitess-cdc/3.0-SNAPSHOT/flink-sql-connector-vitess-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. +**Note:** flink-sql-connector-vitess-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as +[flink-sql-connector-vitess-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-vitess-cdc), +the released version will be available in the Maven central warehouse. + Setup Vitess server ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md index b662b5c9d..ef1e33a50 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md @@ -34,7 +34,7 @@ describes how to setup the db2 CDC connector to run SQL queries against Db2 data | Connector | Database | Driver | |-----------------------|----------------------------------------------------|----------------------| -| [Db2-cdc](db2-cdc.md) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | +| [Db2-cdc](../db2-cdc) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | Dependencies ------------ @@ -53,9 +53,8 @@ using a build automation tool (such as Maven or SBT) and SQL Client with SQL JAR Download flink-sql-connector-db2-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-db2-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users -need to download the source code and compile the corresponding jar. Users should use the released version, such as -[flink-sql-connector-db2-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-db2-cdc), +**Note:** flink-sql-connector-db2-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as +[flink-sql-connector-db2-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-db2-cdc), the released version will be available in the Maven central warehouse. Setup Db2 server diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md index 4525fee67..0f078644b 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md @@ -43,7 +43,7 @@ In order to setup the MongoDB CDC connector, the following table provides depend Download [flink-sql-connector-mongodb-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mongodb-cdc/3.0-SNAPSHOT/flink-sql-connector-mongodb-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-mongodb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mongodb-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-mongodb-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-mongodb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mongodb-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-mongodb-cdc), the released version will be available in the Maven central warehouse. Setup MongoDB ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md index ea75c17ab..50d148ca7 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md @@ -31,9 +31,9 @@ The MySQL CDC connector allows for reading snapshot data and incremental data fr ## Supported Databases -| Connector | Database | Driver | -|-----------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------| -| [mysql-cdc](mysql-cdc.md) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.27 | +| Connector | Database | Driver | +|---------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------| +| [mysql-cdc](../mysql-cdc) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.27 | Dependencies ------------ @@ -50,7 +50,7 @@ In order to setup the MySQL CDC connector, the following table provides dependen Download flink-sql-connector-mysql-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-mysql-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-mysql-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-mysql-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-mysql-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-mysql-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-mysql-cdc), the released version will be available in the Maven central warehouse. Setup MySQL server ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md index 60b196abb..c051dd265 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md @@ -51,7 +51,7 @@ If you want to use OceanBase JDBC driver to connect to the enterprise edition da Download [flink-sql-connector-oceanbase-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oceanbase-cdc/3.0-SNAPSHOT/flink-sql-connector-oceanbase-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-oceanbase-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oceanbase-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oceanbase-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-oceanbase-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oceanbase-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-oceanbase-cdc), the released version will be available in the Maven central warehouse. For JDBC driver, the cdc jar above already contains MySQL JDBC driver 5.1.47, which is our recommended version. Due to the license issue, we can not include the OceanBase JDBC driver in the cdc jar. If you need to use it, you can download it from [here](https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/2.4.2/oceanbase-client-2.4.2.jar) and put it under `/lib/`, you also need to set the start option `jdbc.driver` to `com.oceanbase.jdbc.Driver`. diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md index 9c4bab2b9..36e78e4bd 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md @@ -43,7 +43,7 @@ In order to setup the Oracle CDC connector, the following table provides depende Download [flink-sql-connector-oracle-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-oracle-cdc/3.0-SNAPSHOT/flink-sql-connector-oracle-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-oracle-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oracle-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-oracle-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-oracle-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-oracle-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-oracle-cdc), the released version will be available in the Maven central warehouse. Setup Oracle ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md index f09ca2879..4311ed961 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md @@ -37,15 +37,15 @@ You can also read [tutorials]({{< ref "docs/connectors/legacy-flink-cdc-sources/ | Connector | Database | Driver | |-----------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------| -| [mongodb-cdc](mongodb-cdc.md) |
  • [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 | -| [mysql-cdc](mysql-cdc.md) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 | -| [oceanbase-cdc](oceanbase-cdc.md) |
  • [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x
  • [OceanBase EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x | -| [oracle-cdc](oracle-cdc.md) |
  • [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 | -| [postgres-cdc](postgres-cdc.md) |
  • [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 | -| [sqlserver-cdc](sqlserver-cdc.md) |
  • [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 | -| [tidb-cdc](tidb-cdc.md) |
  • [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 | -| [db2-cdc](db2-cdc.md) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | -| [vitess-cdc](vitess-cdc.md) |
  • [Vitess](https://vitess.io/): 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 | +| [mongodb-cdc](../mongodb-cdc) |
  • [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0 | MongoDB Driver: 4.3.4 | +| [mysql-cdc](../mysql-cdc) |
  • [MySQL](https://dev.mysql.com/doc): 5.6, 5.7, 8.0.x
  • [RDS MySQL](https://www.aliyun.com/product/rds/mysql): 5.6, 5.7, 8.0.x
  • [PolarDB MySQL](https://www.aliyun.com/product/polardb): 5.6, 5.7, 8.0.x
  • [Aurora MySQL](https://aws.amazon.com/cn/rds/aurora): 5.6, 5.7, 8.0.x
  • [MariaDB](https://mariadb.org): 10.x
  • [PolarDB X](https://github.com/ApsaraDB/galaxysql): 2.0.1 | JDBC Driver: 8.0.28 | +| [oceanbase-cdc](../oceanbase-cdc) |
  • [OceanBase CE](https://open.oceanbase.com): 3.1.x, 4.x
  • [OceanBase EE](https://www.oceanbase.com/product/oceanbase): 2.x, 3.x, 4.x | OceanBase Driver: 2.4.x | +| [oracle-cdc](../oracle-cdc) |
  • [Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21 | Oracle Driver: 19.3.0.0 | +| [postgres-cdc](../postgres-cdc) |
  • [PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14 | JDBC Driver: 42.5.1 | +| [sqlserver-cdc](../sqlserver-cdc) |
  • [Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019 | JDBC Driver: 9.4.1.jre8 | +| [tidb-cdc](../tidb-cdc) |
  • [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 | +| [db2-cdc](../db2-cdc) |
  • [Db2](https://www.ibm.com/products/db2): 11.5 | Db2 Driver: 11.5.0.0 | +| [vitess-cdc](../vitess-cdc) |
  • [Vitess](https://vitess.io/): 8.0.x, 9.0.x | MySql JDBC Driver: 8.0.26 | ## Supported Flink Versions The following table shows the version mapping between Flink® CDC Connectors and Flink®: @@ -72,24 +72,24 @@ The following table shows the version mapping between Flink® CDC Con The following table shows the current features of the connector: -| Connector | No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read | -|-----------------------------------|--------------|---------------|-------------------|---------------------------| -| [mongodb-cdc](mongodb-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [mysql-cdc](mysql-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [oracle-cdc](oracle-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [postgres-cdc](postgres-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [sqlserver-cdc](sqlserver-cdc.md) | ✅ | ✅ | ✅ | ✅ | -| [oceanbase-cdc](oceanbase-cdc.md) | ❌ | ❌ | ❌ | ❌ | -| [tidb-cdc](tidb-cdc.md) | ✅ | ❌ | ✅ | ❌ | -| [db2-cdc](db2-cdc.md) | ❌ | ❌ | ✅ | ❌ | -| [vitess-cdc](vitess-cdc.md) | ✅ | ❌ | ✅ | ❌ | +| Connector | No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read | +|--------------------------------|--------------|---------------|-------------------|---------------------------| +| [mongodb-cdc](../mongodb-cdc) | ✅ | ✅ | ✅ | ✅ | +| [mysql-cdc](../mysql-cdc) | ✅ | ✅ | ✅ | ✅ | +| [oracle-cdc](../oracle-cdc) | ✅ | ✅ | ✅ | ✅ | +| [postgres-cdc](../postgres-cdc) | ✅ | ✅ | ✅ | ✅ | +| [sqlserver-cdc](../sqlserver-cdc) | ✅ | ✅ | ✅ | ✅ | +| [oceanbase-cdc](../oceanbase-cdc) | ❌ | ❌ | ❌ | ❌ | +| [tidb-cdc](../tidb-cdc) | ✅ | ❌ | ✅ | ❌ | +| [db2-cdc](../db2-cdc) | ❌ | ❌ | ✅ | ❌ | +| [vitess-cdc](../vitess-cdc) | ✅ | ❌ | ✅ | ❌ | ## Usage for Table/SQL API We need several steps to setup a Flink cluster with the provided connector. 1. Setup a Flink cluster with version 1.12+ and Java 8+ installed. -2. Download the connector SQL jars from the [Downloads](../downloads.md) page (or [build yourself](#building-from-source)). +2. Download the connector SQL jars from the [Downloads](https://github.com/apache/flink-cdc/releases) page (or [build yourself](#building-from-source)). 3. Put the downloaded jars under `FLINK_HOME/lib/`. 4. Restart the Flink cluster. @@ -306,4 +306,19 @@ you can construct `JsonDebeziumDeserializationSchema` as following: new JsonDebeziumDeserializationSchema(true, customConverterConfigs); ``` +## Building from source + +Prerequisites: +- git +- Maven +- At least Java 8 + +``` +git clone https://github.com/apache/flink-cdc.git +cd flink-cdc +mvn clean install -DskipTests +``` + +The dependencies are now available in your local `.m2` repository. + {{< top >}} diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md index 63f3f14d1..cfb7ab9c7 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md @@ -43,7 +43,7 @@ In order to setup the Postgres CDC connector, the following table provides depen Download flink-sql-connector-postgres-cdc-3.0-SNAPSHOT.jar and put it under `/lib/`. -**Note:** flink-sql-connector-postgres-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-postgres-cdc-2.3.0.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-postgres-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-postgres-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-postgres-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-postgres-cdc), the released version will be available in the Maven central warehouse. How to create a Postgres CDC table ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md index 799b5de48..f4f342c1a 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md @@ -43,7 +43,7 @@ In order to setup the SQLServer CDC connector, the following table provides depe Download [flink-sql-connector-sqlserver-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-sqlserver-cdc/3.0-SNAPSHOT/flink-sql-connector-sqlserver-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-sqlserver-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-sqlserver-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-sqlserver-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-sqlserver-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as [flink-sql-connector-sqlserver-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-sqlserver-cdc), the released version will be available in the Maven central warehouse. Setup SQLServer Database ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md index 982ad4116..1348ba381 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md @@ -43,7 +43,7 @@ In order to setup the TiDB CDC connector, the following table provides dependenc Download [flink-sql-connector-tidb-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-tidb-cdc/3.0-SNAPSHOT/flink-sql-connector-tidb-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. -**Note:** flink-sql-connector-tidb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-tidb-cdc-2.2.1.jar](https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-tidb-cdc), the released version will be available in the Maven central warehouse. +**Note:** flink-sql-connector-tidb-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users need to download the source code and compile the corresponding jar. Users should use the released version, such as [flink-sql-connector-tidb-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-sql-connector-tidb-cdc), the released version will be available in the Maven central warehouse. How to create a TiDB CDC table ---------------- diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md b/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md index 9a0919735..0f56654fa 100644 --- a/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md +++ b/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md @@ -42,6 +42,10 @@ In order to setup the Vitess CDC connector, the following table provides depende Download [flink-sql-connector-vitess-cdc-3.0-SNAPSHOT.jar](https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-vitess-cdc/3.0-SNAPSHOT/flink-sql-connector-vitess-cdc-3.0-SNAPSHOT.jar) and put it under `/lib/`. +**Note:** flink-sql-connector-vitess-cdc-XXX-SNAPSHOT version is the code corresponding to the development branch. Users should use the released version, such as +[flink-sql-connector-vitess-cdc-3.0.0.jar](https://mvnrepository.com/artifact/com.ververica/flink-connector-vitess-cdc), +the released version will be available in the Maven central warehouse. + Setup Vitess server ----------------