This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 3d405fba1 [FLINK-39295] Update MySQL docs to reflect MySQL 8.4+
support (#4331)
3d405fba1 is described below
commit 3d405fba1a7c2bd3b9980ebeb3abf172be223483
Author: yuxiqian <[email protected]>
AuthorDate: Tue Mar 24 13:36:10 2026 +0800
[FLINK-39295] Update MySQL docs to reflect MySQL 8.4+ support (#4331)
---
.../docs/connectors/flink-sources/mysql-cdc.md | 16 +++++-
.../docs/connectors/flink-sources/overview.md | 64 +++++++++++-----------
.../connectors/pipeline-connectors/overview.md | 46 ++++++++--------
.../docs/connectors/flink-sources/mysql-cdc.md | 16 +++++-
.../docs/connectors/flink-sources/overview.md | 64 +++++++++++-----------
.../connectors/pipeline-connectors/overview.md | 46 ++++++++--------
6 files changed, 140 insertions(+), 112 deletions(-)
diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
index 53962cd8b..46822cd54 100644
--- a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
@@ -30,9 +30,9 @@ MySQL CDC 连接器允许从 MySQL 数据库读取快照数据和增量数据。
## 支持的数据库
-| Connector | Database
| Driver |
-|-----------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------|
-| 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.27 |
+| Connector | Database
| Driver |
+|-----------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------|
+| mysql-cdc | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <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.27 |
依赖
------------
@@ -122,6 +122,16 @@ mysql> FLUSH PRIVILEGES;
- `wait_timeout`: 服务器在关闭非交互连接之前等待活动的秒数。 更多信息请参考 [MySQL
documentations](https://dev.mysql.com/doc/refman/8.0/en/server-system-variables.html#sysvar_wait_timeout).
+### MySQL 8.4+ 兼容性
+
+MySQL 8.4 引入了一些影响 CDC 连接器的重大变更：
+
+- `SHOW MASTER STATUS` 已被弃用，替换为 `SHOW BINARY LOG STATUS`
+- 错误消息术语从 `slave/master` 变更为 `replica/source`
+
+MySQL CDC 连接器会自动探测 MySQL 服务器版本，并根据服务器版本使用相应的 SQL 语句。这确保了与 MySQL 8.4+
及更早版本的兼容性，无需额外配置。
+
+
如何创建 MySQL CDC 表
----------------
diff --git a/docs/content.zh/docs/connectors/flink-sources/overview.md
b/docs/content.zh/docs/connectors/flink-sources/overview.md
index 4867933a3..6545a3a5b 100644
--- a/docs/content.zh/docs/connectors/flink-sources/overview.md
+++ b/docs/content.zh/docs/connectors/flink-sources/overview.md
@@ -35,39 +35,41 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
## Supported Connectors
-| Connector |
Database
| Driver
|
-|----------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------|
-| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.11.2 |
-| [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 |
-| [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 |
-| [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 |
-| [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 |
-| [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.j [...]
-| [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 [...]
-| [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 |
-| [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 |
+| Connector |
Database
|
Driver [...]
+|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <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 [...]
+| [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 [...]
+| [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 [...]
+| [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 [...]
+| [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. [...]
+| [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 [...]
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySql
JDBC Driver: [...]
## Supported Flink Versions
-The following table shows the version mapping between Flink<sup>®</sup> CDC
Connectors and Flink<sup>®</sup>:
-
-| Flink<sup>®</sup> CDC Version |
Flink<sup>®</sup> Version
|
-|:-----------------------------------:|:--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------:|
-| <font color="DarkCyan">1.0.0</font> |
<font
color="MediumVioletRed">1.11.*</font>
|
-| <font color="DarkCyan">1.1.0</font> |
<font
color="MediumVioletRed">1.11.*</font>
|
-| <font color="DarkCyan">1.2.0</font> |
<font
color="MediumVioletRed">1.12.*</font>
|
-| <font color="DarkCyan">1.3.0</font> |
<font
color="MediumVioletRed">1.12.*</font>
|
-| <font color="DarkCyan">1.4.0</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.0.*</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.1.*</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.2.*</font> |
<font
color="MediumVioletRed">1.13.\*</font>, <font
color="MediumVioletRed">1.14.\*</font>
|
-| <font color="DarkCyan">2.3.*</font> |
<font color="MediumVioletRed">1.13.\*</font>, <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font> |
-| <font color="DarkCyan">2.4.*</font> | <font
color="MediumVioletRed">1.13.\*</font>, <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font> |
-| <font color="DarkCyan">3.0.*</font> | <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font> |
-| <font color="DarkCyan">3.1.*</font> |
<font color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> |
-| <font color="DarkCyan">3.2.*</font> |
<font color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> |
-| <font color="DarkCyan">3.3.*</font> |
<font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font>
|
-| <font color="DarkCyan">3.4.*</font> |
<font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font>
|
-| <font color="DarkCyan">3.5.*</font> |
<font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font>
|
+
+下表展示了 Flink CDC 连接器和 Flink 之间的版本映射：
+
+| Flink CDC 版本 | Flink 版本 |
+|:------------:|:-------------------------------------------:|
+| 1.0.0* | 1.11.\* |
+| 1.1.0* | 1.11.\* |
+| 1.2.0* | 1.12.\* |
+| 1.3.0* | 1.12.\* |
+| 1.4.0* | 1.13.\* |
+| 2.0.\* | 1.13.\* |
+| 2.1.\* | 1.13.\* |
+| 2.2.\* | 1.13.\*, 1.14.\* |
+| 2.3.\* | 1.13.\*, 1.14.\*, 1.15.\*, 1.16.\* |
+| 2.4.\* | 1.13.\*, 1.14.\*, 1.15.\*, 1.16.\*, 1.17.\* |
+| 3.0.\* | 1.14.\*, 1.15.\*, 1.16.\*, 1.17.\*, 1.18.\* |
+| 3.1.\* | 1.16.\*, 1.17.\*, 1.18.\*, 1.19.\* |
+| 3.2.\* | 1.17.\*, 1.18.\*, 1.19.\*, 1.20.\* |
+| 3.3.\* | 1.19.\*, 1.20.\* |
+| 3.4.\* | 1.19.\*, 1.20.\* |
+| 3.5.\* | 1.19.\*, 1.20.\* |
+| 3.6.\* | 1.20.\*, 2.2.\* |
## Features
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
index d37262cbd..8dd790840 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
@@ -30,31 +30,33 @@ Flink CDC 提供了可用于 YAML 作业的 Pipeline Source 和 Sink 连接器
## Supported Connectors
-| 连接器
| 类型 | 支持的外部系统
| 下载链接 [...]
-|----------------------------------------------------------------------------------|--------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|------
[...]
-| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x,
3.x.x
| [3.5. [...]
-| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li> [Elasticsearch](https://www.elastic.co/elasticsearch):
6.x, 7.x, 8.x
| [3.5. [...]
-| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/)
| [3.5.0 [...]
-| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/)
| [3.5 [...]
-| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
| [3.5. [...]
-| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <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 | [3.5. [...]
-| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
| [3.5. [...]
-| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
| [3.5. [...]
-| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7, 0.8, 0.9,
1.0
| [3.5. [...]
-| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
| [3.5. [...]
-| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li> [MaxCompute](https://www.aliyun.com/product/maxcompute)
| [3.5. [...]
+| 连接器
| 类型 | 支持的外部系统
| 下载链接 [...]
+|----------------------------------------------------------------------------------|--------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----
[...]
+| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x,
3.x.x
| [3.5 [...]
+| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li> [Elasticsearch](https://www.elastic.co/elasticsearch):
6.x, 7.x, 8.x
| [3.5 [...]
+| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/)
| [3.5 [...]
+| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/)
| [3.5 [...]
+| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
| [3.5 [...]
+| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <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 | [3.5 [...]
+| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
| [3.5 [...]
+| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
| [3.5 [...]
+| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7, 0.8, 0.9,
1.0
| [3.5 [...]
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
| [3.5 [...]
+| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li> [MaxCompute](https://www.aliyun.com/product/maxcompute)
| [3.5 [...]
## Supported Flink Versions
-下表展示了 Flink<sup>®</sup> CDC 管道连接器和 Flink<sup>®</sup> 之间的版本映射
-| Flink<sup>®</sup> CDC Version |
Flink<sup>®</sup> Version
| Pipeline Source | Pipeline Sink
| 备注 |
-|:-----------------------------------:|:----------------------------------------------------------------------------------------------------------------------------------------:|:---------------:|:---------------------------------------------------------------:|:----------------------------------|
-| <font color="DarkCyan">3.0.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font> | Mysql
| StarRocks,Doris |
|
-| <font color="DarkCyan">3.1.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka | 仅 flink-cdc 3.1.1 支持 flink
1.19.* |
-| <font color="DarkCyan">3.2.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka,ElasticSearch |
|
-| <font color="DarkCyan">3.3.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql
| StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute |
|
-| <font color="DarkCyan">3.4.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute,Iceberg |
|
-| <font color="DarkCyan">3.5.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql, Postgres
| StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute,Iceberg,Fluss
| |
+下表展示了 Flink CDC 管道连接器和 Flink 之间的版本映射：
+
+| Flink CDC 版本 | Flink 版本 | Pipeline Source |
Pipeline Sink
| 备注 |
+|:------------:|:-------------------------:|:-------------------------:|:-------------------------------------------------------------------------------------------:|:-------------------------------:|
+| **3.0.x** | 1.17.\*, 1.18.\* | MySQL |
StarRocks, Doris
| |
+| **3.1.x** | 1.17.\*, 1.18.\*, 1.19.\* | MySQL |
StarRocks, Doris, Paimon, Kafka
| 仅 Flink CDC 3.1.1 支持 Flink 1.19 |
+| **3.2.x** | 1.17.\*, 1.18.\*, 1.19.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch
| |
+| **3.3.x** | 1.19.\*, 1.20.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute
| |
+| **3.4.x** | 1.19.\*, 1.20.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute, Iceberg
| |
+| **3.5.x** | 1.19.\*, 1.20.\* | MySQL, PostgreSQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute, Iceberg,
Fluss | |
+| **3.6.x** | 1.20.\*, 2.2.\* | MySQL, PostgreSQL, Oracle |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute, Iceberg,
Fluss, Hudi | |
## Develop Your Own Connector
diff --git a/docs/content/docs/connectors/flink-sources/mysql-cdc.md
b/docs/content/docs/connectors/flink-sources/mysql-cdc.md
index 2752298c2..ad641ef0e 100644
--- a/docs/content/docs/connectors/flink-sources/mysql-cdc.md
+++ b/docs/content/docs/connectors/flink-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 | <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.27 |
+| Connector | Database
| Driver |
+|-----------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------|
+| mysql-cdc | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <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.27 |
Dependencies
------------
@@ -116,6 +116,16 @@ When an initial consistent snapshot is made for large
databases, your establishe
- `wait_timeout`: The number of seconds the server waits for activity on a
noninteractive connection before closing it. See [MySQL
documentations](https://dev.mysql.com/doc/refman/8.0/en/server-system-variables.html#sysvar_wait_timeout).
+### MySQL 8.4+ Compatibility
+
+MySQL 8.4 introduced some breaking changes that affect CDC connectors:
+
+- `SHOW MASTER STATUS` is deprecated and replaced by `SHOW BINARY LOG STATUS`
+- Error message terminology changed from `slave/master` to `replica/source`
+
+The MySQL CDC connector automatically probes the MySQL server version and uses
the appropriate SQL statements based on the server version. This ensures
compatibility with both MySQL 8.4+ and earlier versions without any additional
configuration.
+
+
How to create a MySQL CDC table
----------------
diff --git a/docs/content/docs/connectors/flink-sources/overview.md
b/docs/content/docs/connectors/flink-sources/overview.md
index a1855f3a4..105d4111b 100644
--- a/docs/content/docs/connectors/flink-sources/overview.md
+++ b/docs/content/docs/connectors/flink-sources/overview.md
@@ -35,39 +35,41 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
## Supported Connectors
-| Connector |
Database
| Driver
|
-|----------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------|
-| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.11.2 |
-| [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 |
-| [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 |
-| [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 |
-| [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 |
-| [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.j [...]
-| [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 [...]
-| [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 |
-| [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 |
+| Connector |
Database
|
Driver [...]
+|----------------------------------------------------------------------------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|--------------------
[...]
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
<li> [MongoDB](https://www.mongodb.com): 3.6, 4.x, 5.0, 6.0, 6.1, 7.0
|
MongoDB Driver: 4.1 [...]
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
<li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x, 8.4+ <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 [...]
+| [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 [...]
+| [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 [...]
+| [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 [...]
+| [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. [...]
+| [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 [...]
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
<li> [Db2](https://www.ibm.com/products/db2): 11.5
| Db2
Driver: 11.5.0. [...]
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
<li> [Vitess](https://vitess.io/): 8.0.x, 9.0.x
| MySql
JDBC Driver: [...]
## Supported Flink Versions
-The following table shows the version mapping between Flink<sup>®</sup> CDC
Connectors and Flink<sup>®</sup>:
-
-| Flink<sup>®</sup> CDC Version |
Flink<sup>®</sup>
Version
|
-|:-----------------------------------:|:------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------:|
-| <font color="DarkCyan">1.0.0</font> |
<font
color="MediumVioletRed">1.11.*</font>
|
-| <font color="DarkCyan">1.1.0</font> |
<font
color="MediumVioletRed">1.11.*</font>
|
-| <font color="DarkCyan">1.2.0</font> |
<font
color="MediumVioletRed">1.12.*</font>
|
-| <font color="DarkCyan">1.3.0</font> |
<font
color="MediumVioletRed">1.12.*</font>
|
-| <font color="DarkCyan">1.4.0</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.0.*</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.1.*</font> |
<font
color="MediumVioletRed">1.13.*</font>
|
-| <font color="DarkCyan">2.2.*</font> |
<font color="MediumVioletRed">1.13.\*</font>,
<font color="MediumVioletRed">1.14.\*</font>
|
-| <font color="DarkCyan">2.3.*</font> | <font
color="MediumVioletRed">1.13.\*</font>, <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font> |
-| <font color="DarkCyan">2.4.*</font> | <font
color="MediumVioletRed">1.13.\*</font>, <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font> |
-| <font color="DarkCyan">3.0.*</font> | <font
color="MediumVioletRed">1.14.\*</font>, <font
color="MediumVioletRed">1.15.\*</font>, <font
color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font> |
-| <font color="DarkCyan">3.1.*</font> | <font
color="MediumVioletRed">1.16.\*</font>, <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> |
-| <font color="DarkCyan">3.2.*</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> |
-| <font color="DarkCyan">3.3.*</font> |
<font color="MediumVioletRed">1.19.\*</font>,
<font color="MediumVioletRed">1.20.\*</font>
|
-| <font color="DarkCyan">3.4.*</font> |
<font color="MediumVioletRed">1.19.\*</font>,
<font color="MediumVioletRed">1.20.\*</font>
|
-| <font color="DarkCyan">3.5.*</font> |
<font color="MediumVioletRed">1.19.\*</font>,
<font color="MediumVioletRed">1.20.\*</font>
|
+
+The following table shows the version mapping between Flink CDC Connectors and
Flink:
+
+| Flink CDC Version | Flink Version |
+|:-----------------:|:-------------------------------------------:|
+| 1.0.0* | 1.11.\* |
+| 1.1.0* | 1.11.\* |
+| 1.2.0* | 1.12.\* |
+| 1.3.0* | 1.12.\* |
+| 1.4.0* | 1.13.\* |
+| 2.0.\* | 1.13.\* |
+| 2.1.\* | 1.13.\* |
+| 2.2.\* | 1.13.\*, 1.14.\* |
+| 2.3.\* | 1.13.\*, 1.14.\*, 1.15.\*, 1.16.\* |
+| 2.4.\* | 1.13.\*, 1.14.\*, 1.15.\*, 1.16.\*, 1.17.\* |
+| 3.0.\* | 1.14.\*, 1.15.\*, 1.16.\*, 1.17.\*, 1.18.\* |
+| 3.1.\* | 1.16.\*, 1.17.\*, 1.18.\*, 1.19.\* |
+| 3.2.\* | 1.17.\*, 1.18.\*, 1.19.\*, 1.20.\* |
+| 3.3.\* | 1.19.\*, 1.20.\* |
+| 3.4.\* | 1.19.\*, 1.20.\* |
+| 3.5.\* | 1.19.\*, 1.20.\* |
+| 3.6.\* | 1.20.\*, 2.2.\* |
## Features
diff --git a/docs/content/docs/connectors/pipeline-connectors/overview.md
b/docs/content/docs/connectors/pipeline-connectors/overview.md
index 21afef264..bcd9f9ea4 100644
--- a/docs/content/docs/connectors/pipeline-connectors/overview.md
+++ b/docs/content/docs/connectors/pipeline-connectors/overview.md
@@ -33,32 +33,34 @@ definition.
## Supported Connectors
-| Connector
| Supported Type | External System
[...]
-|----------------------------------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
-| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x,
2.x.x, 3.x.x
[...]
-| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li>
[Elasticsearch](https://www.elastic.co/elasticsearch): 6.x, 7.x, 8.x
[...]
-| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/)
[...]
-| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/)
[...]
-| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
[...]
-| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <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 [...]
-| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
[...]
-| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
[...]
-| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7,
0.8, 0.9, 1.0
[...]
-| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
[...]
-| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li>
[MaxCompute](https://www.aliyun.com/product/maxcompute)
[...]
+| Connector
| Supported Type | External System
[...]
+|----------------------------------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[...]
+| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}})
| Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x,
2.x.x, 3.x.x
[...]
+| [Elasticsearch]({{< ref "docs/connectors/pipeline-connectors/elasticsearch"
>}}) | Sink | <li>
[Elasticsearch](https://www.elastic.co/elasticsearch): 6.x, 7.x, 8.x
[...]
+| [Iceberg]({{< ref "docs/connectors/pipeline-connectors/iceberg" >}})
| Sink | <li> [Apache Iceberg](https://iceberg.apache.org/)
[...]
+| [Fluss]({{< ref "docs/connectors/pipeline-connectors/fluss" >}})
| Sink | <li> [Fluss](https://fluss.apache.org/)
[...]
+| [Kafka]({{< ref "docs/connectors/pipeline-connectors/kafka" >}})
| Sink | <li> [Kafka](https://kafka.apache.org/)
[...]
+| [MySQL]({{< ref "docs/connectors/pipeline-connectors/mysql" >}})
| Source | <li> [MySQL](https://dev.mysql.com/doc): 5.7, 8.0.x,
8.4+ <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. [...]
+| [Postgres]({{< ref "docs/connectors/pipeline-connectors/postgres" >}})
| Source | <li> [PostgreSQL](https://www.postgresql.org/)
[...]
+| [OceanBase]({{< ref "docs/connectors/pipeline-connectors/oceanbase" >}})
| Sink | <li> [OceanBase](https://www.oceanbase.com/): 3.x, 4.x
[...]
+| [Paimon]({{< ref "docs/connectors/pipeline-connectors/paimon" >}})
| Sink | <li> [Paimon](https://paimon.apache.org/): 0.6, 0.7,
0.8, 0.9, 1.0
[...]
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}})
| Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
[...]
+| [MaxCompute]({{< ref "docs/connectors/pipeline-connectors/maxcompute" >}})
| Sink | <li>
[MaxCompute](https://www.aliyun.com/product/maxcompute)
[...]
## Supported Flink Versions
-The following table shows the version mapping between Flink<sup>®</sup> CDC
Pipeline Connectors and Flink<sup>®</sup>
-| Flink<sup>®</sup> CDC Version |
Flink<sup>®</sup> Version
| Pipeline Source | Pipeline Sink
| Notes |
-|:-----------------------------------:|:----------------------------------------------------------------------------------------------------------------------------------------:|:---------------:|:---------------------------------------------------------------:|:-----------------------------------------:|
-| <font color="DarkCyan">3.0.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font> | Mysql
| StarRocks,Doris |
|
-| <font color="DarkCyan">3.1.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka | only flink-cdc 3.1.1 support
flink 1.19.* |
-| <font color="DarkCyan">3.2.x</font> | <font
color="MediumVioletRed">1.17.\*</font>, <font
color="MediumVioletRed">1.18.\*</font>, <font
color="MediumVioletRed">1.19.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka,ElasticSearch |
|
-| <font color="DarkCyan">3.3.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql
| StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute |
|
-| <font color="DarkCyan">3.4.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql |
StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute,Iceberg |
|
-| <font color="DarkCyan">3.5.x</font> | <font
color="MediumVioletRed">1.19.\*</font>, <font
color="MediumVioletRed">1.20.\*</font> | Mysql, Postgres
| StarRocks,Doris,Paimon,Kafka,ElasticSearch,OceanBase,MaxCompute,Iceberg,Fluss
| |
+The following table shows the version mapping between Flink CDC Pipeline
Connectors and Flink:
+
+| Flink CDC Version | Flink Version | Pipeline Source |
Pipeline Sink
| Notes |
+|:-----------------:|:-------------------------:|:-------------------------:|:-------------------------------------------------------------------------------------------:|:----------------------------------------:|
+| **3.0.x** | 1.17.\*, 1.18.\* | MySQL |
StarRocks, Doris
| |
+| **3.1.x** | 1.17.\*, 1.18.\*, 1.19.\* | MySQL |
StarRocks, Doris, Paimon, Kafka
| Only flink-cdc 3.1.1 supports Flink 1.19 |
+| **3.2.x** | 1.17.\*, 1.18.\*, 1.19.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch
| |
+| **3.3.x** | 1.19.\*, 1.20.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute
| |
+| **3.4.x** | 1.19.\*, 1.20.\* | MySQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute,
Iceberg | |
+| **3.5.x** | 1.19.\*, 1.20.\* | MySQL, PostgreSQL |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute,
Iceberg, Fluss | |
+| **3.6.x** | 1.20.\*, 2.2.\* | MySQL, PostgreSQL, Oracle |
StarRocks, Doris, Paimon, Kafka, Elasticsearch, OceanBase, MaxCompute, Iceberg,
Fluss, Hudi | |
## Develop Your Own Connector
