This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch release-3.0
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.0 by this push:
new 417971062 [minor][docs] Rectify names of CDC sources for Flink and
improve the content directory
417971062 is described below
commit 4179710625ed99f00058e5b641030f59d03e6343
Author: yux <34335406+yuxiq...@users.noreply.github.com>
AuthorDate: Wed May 22 21:41:12 2024 +0800
[minor][docs] Rectify names of CDC sources for Flink and improve the
content directory
This closes #3315.
---
README.md | 2 +-
.../docs/connectors/flink-sources}/_index.md | 4 +-
.../datastream-api-package-guidance.md | 2 +-
.../db2-cdc.md | 4 +-
.../mongodb-cdc.md | 4 +-
.../mysql-cdc.md | 4 +-
.../oceanbase-cdc.md | 6 +--
.../docs/connectors/flink-sources}/oracle-cdc.md | 4 +-
.../overview.md | 58 +++++++++++-----------
.../docs/connectors/flink-sources}/postgres-cdc.md | 4 +-
.../sqlserver-cdc.md | 4 +-
.../tidb-cdc.md | 2 +-
.../tutorials/_index.md | 2 +-
.../build-real-time-data-lake-tutorial.md | 2 +-
.../tutorials/build-streaming-etl-tutorial.md | 2 +-
.../tutorials/db2-tutorial.md | 2 +-
.../tutorials/mongodb-tutorial.md | 2 +-
.../tutorials/oceanbase-tutorial.md | 2 +-
.../tutorials/oracle-tutorial.md | 2 +-
.../tutorials/polardbx-tutorial.md | 2 +-
.../tutorials/sqlserver-tutorial.md | 2 +-
.../tutorials/tidb-tutorial.md | 2 +-
.../vitess-cdc.md | 2 +-
.../_index.md | 4 +-
.../connectors/{ => pipeline-connectors}/doris.md | 4 +-
.../connectors/{ => pipeline-connectors}/mysql.md | 2 +-
.../{ => pipeline-connectors}/overview.md | 19 +++----
.../{ => pipeline-connectors}/starrocks.md | 4 +-
docs/content.zh/docs/deployment/kubernetes.md | 6 +--
docs/content.zh/docs/deployment/standalone.md | 6 +--
docs/content.zh/docs/deployment/yarn.md | 2 +-
.../tutorials => flink-sources}/_index.md | 4 +-
.../datastream-api-package-guidance.md | 2 +-
.../db2-cdc.md | 4 +-
.../mongodb-cdc.md | 4 +-
.../mysql-cdc.md | 4 +-
.../oceanbase-cdc.md | 6 +--
.../docs/connectors/flink-sources}/oracle-cdc.md | 4 +-
.../overview.md | 58 +++++++++++-----------
.../docs/connectors/flink-sources}/postgres-cdc.md | 4 +-
.../sqlserver-cdc.md | 4 +-
.../tidb-cdc.md | 2 +-
.../tutorials/_index.md | 0
.../build-real-time-data-lake-tutorial.md | 2 +-
.../tutorials/build-streaming-etl-tutorial.md | 2 +-
.../tutorials/db2-tutorial.md | 2 +-
.../tutorials/mongodb-tutorial.md | 2 +-
.../tutorials/oceanbase-tutorial.md | 2 +-
.../tutorials/oracle-tutorial.md | 2 +-
.../tutorials/polardbx-tutorial.md | 2 +-
.../tutorials/sqlserver-tutorial.md | 2 +-
.../tutorials/tidb-tutorial.md | 2 +-
.../vitess-cdc.md | 2 +-
.../docs/connectors/pipeline-connectors}/_index.md | 4 +-
.../connectors/{ => pipeline-connectors}/doris.md | 4 +-
.../connectors/{ => pipeline-connectors}/mysql.md | 2 +-
.../{ => pipeline-connectors}/overview.md | 19 +++----
.../{ => pipeline-connectors}/starrocks.md | 4 +-
docs/content/docs/deployment/kubernetes.md | 6 +--
docs/content/docs/deployment/standalone.md | 6 +--
docs/content/docs/deployment/yarn.md | 2 +-
61 files changed, 160 insertions(+), 170 deletions(-)
diff --git a/README.md b/README.md
index 46676e224..6b567555d 100644
--- a/README.md
+++ b/README.md
@@ -63,7 +63,7 @@ full database synchronization, sharding table
synchronization, schema evolution
5. View job execution status through Flink WebUI or downstream database.
Try it out yourself with our more detailed
[tutorial](docs/content/docs/get-started/quickstart/mysql-to-doris.md).
-You can also see [connector
overview](docs/content/docs/connectors/overview.md) to view a comprehensive
catalog of the
+You can also see [connector
overview](docs/content/docs/connectors/pipeline-connectors/overview.md) to view
a comprehensive catalog of the
connectors currently provided and understand more detailed configurations.
diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/_index.md
b/docs/content.zh/docs/connectors/flink-sources/_index.md
similarity index 95%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/_index.md
rename to docs/content.zh/docs/connectors/flink-sources/_index.md
index 11aed50f2..f214713dd 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/_index.md
+++ b/docs/content.zh/docs/connectors/flink-sources/_index.md
@@ -1,7 +1,7 @@
---
-title: Legacy Flink CDC Sources
+title: Flink Source 连接器
bookCollapseSection: true
-weight: 5
+weight: 2
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
b/docs/content.zh/docs/connectors/flink-sources/datastream-api-package-guidance.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
rename to
docs/content.zh/docs/connectors/flink-sources/datastream-api-package-guidance.md
index 18295e70e..ce5f34082 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
+++
b/docs/content.zh/docs/connectors/flink-sources/datastream-api-package-guidance.md
@@ -3,7 +3,7 @@ title: "DataStream API 打包指南"
weight: 998
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/datastream-api-package-guidance
+- /connectors/flink-sources/datastream-api-package-guidance
---
<!--
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/db2-cdc.md
similarity index 99%
rename from docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/db2-cdc.md
index 273ec305d..ef06c1b3e 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/db2-cdc.md
@@ -1,9 +1,9 @@
---
title: "Db2"
-weight: 9
+weight: 7
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/db2-cdc
+- /connectors/flink-sources/db2-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
index c413b496d..cbf82eb17 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
@@ -1,9 +1,9 @@
---
title: "MongoDB"
-weight: 2
+weight: 6
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/mongodb-cdc
+- /connectors/flink-sources/mongodb-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
index 68c2889d9..e42728730 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
@@ -1,9 +1,9 @@
---
title: "MySQL"
-weight: 7
+weight: 2
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/mysql-cdc
+- /connectors/flink-sources/mysql-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md
index 80f19f9ae..fea17f2dd 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md
@@ -1,9 +1,9 @@
---
title: "OceanBase"
-weight: 4
+weight: 9
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/oceanbase-cdc
+- /connectors/flink-sources/oceanbase-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -154,7 +154,7 @@ Flink SQL> CREATE TABLE orders (
);
```
-您也可以访问 Flink CDC 官网文档，快速体验将数据从 OceanBase 导入到 Elasticsearch。更多信息，参考 [Flink CDC
官网文档](https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial/)。
+您也可以访问 Flink CDC 官网文档，快速体验将数据从 OceanBase 导入到 Elasticsearch。更多信息，参考 [Flink CDC
官网文档]({{< ref "docs/connectors/flink-sources/tutorials/oceanbase-tutorial" >}})。
## OceanBase CDC 连接器选项
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md
index c0e77e8e2..9f17cd7af 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md
@@ -1,9 +1,9 @@
---
title: "Oracle"
-weight: 5
+weight: 3
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/oracle-cdc
+- /connectors/flink-sources/oracle-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md
b/docs/content.zh/docs/connectors/flink-sources/overview.md
similarity index 73%
rename from docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md
rename to docs/content.zh/docs/connectors/flink-sources/overview.md
index c84d57945..0e8fe1052 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/overview.md
+++ b/docs/content.zh/docs/connectors/flink-sources/overview.md
@@ -3,7 +3,7 @@ title: "概览"
weight: 1
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/
+- /connectors/flink-sources/
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -24,28 +24,28 @@ specific language governing permissions and limitations
under the License.
-->
-# Legacy CDC sources
+# Flink Sources 连接器
-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).
+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).
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).
-You can also read [tutorials]({{< ref
"docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial"
>}}) about how to use these sources.
+You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial" >}})
about how to use these sources.
{{< img src="/fig/cdc-flow.png" width="600px" alt="Flink CDC" >}}
## Supported Connectors
-| Connector | Database
| Driver |
-|-----------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------|
-| [mongodb-cdc](../mongodb-cdc) | <li> [MongoDB](https://www.mongodb.com):
3.6, 4.x, 5.0
| MongoDB Driver: 4.3.4 |
-| [mysql-cdc](../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](../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](../oracle-cdc) | <li>
[Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
| Oracle
Driver: 19.3.0.0 |
-| [postgres-cdc](../postgres-cdc) | <li>
[PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 |
-| [sqlserver-cdc](../sqlserver-cdc) | <li>
[Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019
| JDBC
Driver: 9.4.1.jre8 |
-| [tidb-cdc](../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](../db2-cdc) | <li>
[Db2](https://www.ibm.com/products/db2): 11.5
| Db2 Driver:
11.5.0.0 |
-| [vitess-cdc](../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
|
MongoDB Driver: 4.3.4 |
+| [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 |
## Supported Flink Versions
The following table shows the version mapping between Flink<sup>®</sup> CDC
Connectors and Flink<sup>®</sup>:
@@ -72,17 +72,17 @@ The following table shows the version mapping between
Flink<sup>®</sup> 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) | ✅ | ✅ | ✅
| ✅ |
-| [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) | ✅ | ❌ | ✅
| ❌ |
+| Connector |
No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read |
+|----------------------------------------------------------------------------|--------------|---------------|-------------------|---------------------------|
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
❌ | ❌ | ❌ | ❌ |
+| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
✅ | ❌ | ✅ | ❌ |
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
❌ | ❌ | ✅ | ❌ |
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
✅ | ❌ | ✅ | ❌ |
## Usage for Table/SQL API
@@ -123,7 +123,7 @@ Include following Maven dependency (available through Maven
Central):
```
<dependency>
- <groupId>com.ververica</groupId>
+ <groupId>org.apache.flink</groupId>
<!-- add the dependency matching your database -->
<artifactId>flink-connector-mysql-cdc</artifactId>
<!-- The dependency is available only for stable releases, SNAPSHOT
dependencies need to be built based on master or release branches by yourself.
-->
@@ -133,8 +133,8 @@ Include following Maven dependency (available through Maven
Central):
```java
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
public class MySqlBinlogSourceExample {
public static void main(String[] args) throws Exception {
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md
index 4e4bfbf0b..3e54855a4 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md
@@ -1,9 +1,9 @@
---
title: "Postgres"
-weight: 6
+weight: 5
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/postgres-cdc
+- /connectors/flink-sources/postgres-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md
index e66813c44..abc2779ef 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md
@@ -1,9 +1,9 @@
---
title: "SQL Server"
-weight: 7
+weight: 4
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/sqlserver-cdc
+- /connectors/flink-sources/sqlserver-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/tidb-cdc.md
similarity index 99%
rename from docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/tidb-cdc.md
index f0865859f..6ac2db6ba 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/tidb-cdc.md
@@ -3,7 +3,7 @@ title: "TiDB"
weight: 8
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tidb-cdc
+- /connectors/flink-sources/tidb-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/_index.md
similarity index 95%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
rename to docs/content.zh/docs/connectors/flink-sources/tutorials/_index.md
index 8582b9b76..efae6fffc 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
+++ b/docs/content.zh/docs/connectors/flink-sources/tutorials/_index.md
@@ -1,5 +1,5 @@
---
-title: "Legacy CDC Sources 教程"
+title: "Flink CDC Sources 教程"
bookCollapseSection: true
weight: 999
---
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
index 0f2fe0a9b..916a2a316 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
@@ -3,7 +3,7 @@ title: "使用 Flink CDC 构建实时数据湖"
weight: 998
type: docs
aliases:
--
/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.html
+- /connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.html
---
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
index f6e2b0a58..905a2a60c 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
@@ -3,7 +3,7 @@ title: "使用 Flink CDC 构建 Streaming ETL"
weight: 999
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mysql-postgres-tutorial.html
+- /connectors/flink-sources/tutorials/mysql-postgres-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/db2-tutorial.md
similarity index 98%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/db2-tutorial.md
index 722da0ae0..00d54d843 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
+++ b/docs/content.zh/docs/connectors/flink-sources/tutorials/db2-tutorial.md
@@ -3,7 +3,7 @@ title: "Db2 教程"
weight: 2
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.html
+- /connectors/flink-sources/tutorials/db2-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
similarity index 98%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
index b8a33e217..c4126327c 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
@@ -3,7 +3,7 @@ title: "MongoDB 教程"
weight: 1
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.html
+- /connectors/flink-sources/tutorials/mongodb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
index d0a06fd62..e4ce64a7e 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
@@ -3,7 +3,7 @@ title: "OceanBase 教程"
weight: 3
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.html
+- /connectors/flink-sources/tutorials/oceanbase-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
index 649f34976..6b4ec1125 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
+++ b/docs/content.zh/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
@@ -3,7 +3,7 @@ title: "Oracle 教程"
weight: 4
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.html
+- /connectors/flink-sources/tutorials/oracle-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
index fce4be25d..e83ca5389 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
@@ -3,7 +3,7 @@ title: "PolarDB-X 教程"
weight: 5
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.html
+- /connectors/flink-sources/tutorials/mongodb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
index 89f22a31f..e7ee22501 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
+++
b/docs/content.zh/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
@@ -3,7 +3,7 @@ title: "SqlServer 教程"
weight: 6
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.html
+- /connectors/flink-sources/tutorials/sqlserver-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
b/docs/content.zh/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
rename to
docs/content.zh/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
index b4994d2ea..a0ecee1fb 100644
---
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
+++ b/docs/content.zh/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
@@ -3,7 +3,7 @@ title: "TiDB 教程"
weight: 7
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.html
+- /connectors/flink-sources/tutorials/tidb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/vitess-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
rename to docs/content.zh/docs/connectors/flink-sources/vitess-cdc.md
index b589374ce..94bbf1311 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/vitess-cdc.md
@@ -3,7 +3,7 @@ title: "Vitess"
weight: 10
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/vitess-cdc
+- /connectors/flink-sources/vitess-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
b/docs/content.zh/docs/connectors/pipeline-connectors/_index.md
similarity index 95%
copy from docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
copy to docs/content.zh/docs/connectors/pipeline-connectors/_index.md
index e636a211d..589eecdbd 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/_index.md
@@ -1,7 +1,7 @@
---
-title: Legacy CDC Sources
+title: Pipeline 连接器
bookCollapseSection: true
-weight: 5
+weight: 1
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/connectors/doris.md
b/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
similarity index 99%
rename from docs/content.zh/docs/connectors/doris.md
rename to docs/content.zh/docs/connectors/pipeline-connectors/doris.md
index 00ac8cfcf..bdbb5fe2c 100644
--- a/docs/content.zh/docs/connectors/doris.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/doris.md
@@ -1,9 +1,9 @@
---
title: "Doris"
-weight: 3
+weight: 5
type: docs
aliases:
-- /connectors/doris
+- /connectors/pipeline-connectors/doris
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/connectors/mysql.md
b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md
similarity index 99%
rename from docs/content.zh/docs/connectors/mysql.md
rename to docs/content.zh/docs/connectors/pipeline-connectors/mysql.md
index 21dcce767..133bc6983 100644
--- a/docs/content.zh/docs/connectors/mysql.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md
@@ -3,7 +3,7 @@ title: "MySQL"
weight: 2
type: docs
aliases:
-- /connectors/mysql
+- /connectors/pipeline-connectors/mysql
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/connectors/overview.md
b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
similarity index 57%
rename from docs/content.zh/docs/connectors/overview.md
rename to docs/content.zh/docs/connectors/pipeline-connectors/overview.md
index 3743d72bc..bfba684bd 100644
--- a/docs/content.zh/docs/connectors/overview.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/overview.md
@@ -3,7 +3,7 @@ title: "概览"
weight: 1
type: docs
aliases:
- - /connectors/overview
+ - /connectors/pipeline-connectors/overview
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -24,23 +24,20 @@ specific language governing permissions and limitations
under the License.
-->
-# Connectors
+# Pipeline Connectors
-Flink CDC 提供了多个Source和Sink连接器来与外部系统交互。您可以直接使用这些连接器，只需将 JAR 文件添加到您的 Flink CDC
环境中，并在您的 YAML Pipeline定义中指定所需的连接器。
+Flink CDC 提供了可用于 YAML 作业的 Pipeline Source 和 Sink 连接器来与外部系统交互。您可以直接使用这些连接器，只需将
JAR 文件添加到您的 Flink CDC 环境中，并在您的 YAML Pipeline 定义中指定所需的连接器。
## Supported Connectors
-| Connector | Supported Type |
External System
|
-|------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| [Apache Doris]({{< ref "docs/connectors/doris" >}}) | Sink | <li>
[Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x
|
-| [MySQL]({{< ref "docs/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 |
-| [StarRocks]({{< ref "docs/connectors/starrocks" >}}) | Sink | <li>
[StarRocks](https://www.starrocks.io/): 2.x, 3.x
|
+| 连接器 |
类型 | 支持的外部系统
|
+|--------------------------------------------------------------------------|--------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| [Apache Doris]({{< ref "docs/connectors/pipeline-connectors/doris" >}}) |
Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x
|
+| [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 |
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}}) |
Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
|
## Develop Your Own Connector
如果现有的连接器无法满足您的需求，您可以自行开发自己的连接器，以将您的外部系统集成到 Flink CDC 数据管道中。查阅 [Flink CDC
APIs]({{< ref "docs/developer-guide/understand-flink-cdc-api" >}})
了解如何开发您自己的连接器。
-## Legacy Flink CDC Sources
-在 3.0 版本之前引入的 Flink CDC Source 仍然可以作为普通的 Flink 连接器使用。您可以在 [Legacy CDC
Sources/概览]({{< ref "docs/connectors/legacy-flink-cdc-sources/overview" >}})
中找到更多详细信息。
-
{{< top >}}
diff --git a/docs/content.zh/docs/connectors/starrocks.md
b/docs/content.zh/docs/connectors/pipeline-connectors/starrocks.md
similarity index 99%
rename from docs/content.zh/docs/connectors/starrocks.md
rename to docs/content.zh/docs/connectors/pipeline-connectors/starrocks.md
index 6a72a25ff..eba6c2d87 100644
--- a/docs/content.zh/docs/connectors/starrocks.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/starrocks.md
@@ -1,9 +1,9 @@
---
title: "StarRocks"
-weight: 4
+weight: 6
type: docs
aliases:
-- /connectors/starrocks
+- /connectors/pipeline-connectors/starrocks
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/deployment/kubernetes.md
b/docs/content.zh/docs/deployment/kubernetes.md
index 158757276..95539112b 100644
--- a/docs/content.zh/docs/deployment/kubernetes.md
+++ b/docs/content.zh/docs/deployment/kubernetes.md
@@ -48,7 +48,7 @@ If you have problems setting up a Kubernetes cluster, please
take a look at [how
## Session Mode
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
@@ -134,8 +134,8 @@ pipeline:
```
You need to modify the configuration file according to your needs, refer to
connectors more information.
-- [MySQL pipeline connector]({{< ref "docs/connectors/mysql.md" >}})
-- [Apache Doris pipeline connector]({{< ref "docs/connectors/doris.md" >}})
+- [MySQL pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/mysql.md" >}})
+- [Apache Doris pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/doris.md" >}})
Finally, submit job to Flink Standalone cluster using Cli.
diff --git a/docs/content.zh/docs/deployment/standalone.md
b/docs/content.zh/docs/deployment/standalone.md
index dd052bcab..aa30db51e 100644
--- a/docs/content.zh/docs/deployment/standalone.md
+++ b/docs/content.zh/docs/deployment/standalone.md
@@ -32,7 +32,7 @@ You will also run an example Flink CDC job and view it in the
web UI.
## Preparation
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
@@ -111,8 +111,8 @@ pipeline:
```
You need to modify the configuration file according to your needs, refer to
connectors more information.
-- [MySQL pipeline connector]({{< ref "docs/connectors/mysql.md" >}})
-- [Apache Doris pipeline connector]({{< ref "docs/connectors/doris.md" >}})
+- [MySQL pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/mysql.md" >}})
+- [Apache Doris pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/doris.md" >}})
Finally, submit job to Flink Standalone cluster using Cli.
diff --git a/docs/content.zh/docs/deployment/yarn.md
b/docs/content.zh/docs/deployment/yarn.md
index ec9700d89..5f6236a64 100644
--- a/docs/content.zh/docs/deployment/yarn.md
+++ b/docs/content.zh/docs/deployment/yarn.md
@@ -46,7 +46,7 @@ export HADOOP_CLASSPATH=`hadoop classpath`
## Session Mode
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
b/docs/content/docs/connectors/flink-sources/_index.md
similarity index 96%
copy from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
copy to docs/content/docs/connectors/flink-sources/_index.md
index 7c83c335c..5e2d512e3 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
+++ b/docs/content/docs/connectors/flink-sources/_index.md
@@ -1,7 +1,7 @@
---
-title: Tutorials
+title: Flink Sources
bookCollapseSection: true
-weight: 999
+weight: 2
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
b/docs/content/docs/connectors/flink-sources/datastream-api-package-guidance.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
rename to
docs/content/docs/connectors/flink-sources/datastream-api-package-guidance.md
index a2fc247d3..eaadc86a2 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/datastream-api-package-guidance.md
+++
b/docs/content/docs/connectors/flink-sources/datastream-api-package-guidance.md
@@ -3,7 +3,7 @@ title: "DataStream API Package Guidance"
weight: 998
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/datastream-api-package-guidance
+- /connectors/flink-sources/datastream-api-package-guidance
---
<!--
diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
b/docs/content/docs/connectors/flink-sources/db2-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
rename to docs/content/docs/connectors/flink-sources/db2-cdc.md
index 273ec305d..ef06c1b3e 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/db2-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/db2-cdc.md
@@ -1,9 +1,9 @@
---
title: "Db2"
-weight: 9
+weight: 7
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/db2-cdc
+- /connectors/flink-sources/db2-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
b/docs/content/docs/connectors/flink-sources/mongodb-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
rename to docs/content/docs/connectors/flink-sources/mongodb-cdc.md
index a3a0cb9af..9cb9535fa 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/mongodb-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/mongodb-cdc.md
@@ -1,9 +1,9 @@
---
title: "MongoDB"
-weight: 2
+weight: 6
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/mongodb-cdc
+- /connectors/flink-sources/mongodb-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
b/docs/content/docs/connectors/flink-sources/mysql-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
rename to docs/content/docs/connectors/flink-sources/mysql-cdc.md
index 516b16abf..ec28c1cca 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/mysql-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/mysql-cdc.md
@@ -1,9 +1,9 @@
---
title: "MySQL"
-weight: 7
+weight: 2
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/mysql-cdc
+- /connectors/flink-sources/mysql-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
b/docs/content/docs/connectors/flink-sources/oceanbase-cdc.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
rename to docs/content/docs/connectors/flink-sources/oceanbase-cdc.md
index 1b8372336..ec8bf6e48 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/oceanbase-cdc.md
@@ -1,9 +1,9 @@
---
title: "OceanBase"
-weight: 4
+weight: 9
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/oceanbase-cdc
+- /connectors/flink-sources/oceanbase-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -152,7 +152,7 @@ Flink SQL> CREATE TABLE orders (
);
```
-You can also try the quickstart tutorial that sync data from OceanBase to
Elasticsearch, please refer [Flink CDC Tutorial]({{< ref
"docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial" >}})
for more information.
+You can also try the quickstart tutorial that sync data from OceanBase to
Elasticsearch, please refer [Flink CDC Tutorial]({{< ref
"docs/connectors/flink-sources/tutorials/oceanbase-tutorial" >}}) for more
information.
Connector Options
----------------
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
b/docs/content/docs/connectors/flink-sources/oracle-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
rename to docs/content/docs/connectors/flink-sources/oracle-cdc.md
index c0e77e8e2..9f17cd7af 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/oracle-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/oracle-cdc.md
@@ -1,9 +1,9 @@
---
title: "Oracle"
-weight: 5
+weight: 3
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/oracle-cdc
+- /connectors/flink-sources/oracle-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md
b/docs/content/docs/connectors/flink-sources/overview.md
similarity index 73%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md
rename to docs/content/docs/connectors/flink-sources/overview.md
index f50b0bfa3..13b33d7f3 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md
+++ b/docs/content/docs/connectors/flink-sources/overview.md
@@ -3,7 +3,7 @@ title: "Overview"
weight: 1
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/
+- /connectors/flink-sources/overview
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -24,28 +24,28 @@ specific language governing permissions and limitations
under the License.
-->
-# Legacy CDC sources
+# Flink CDC sources
-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).
+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).
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).
-You can also read [tutorials]({{< ref
"docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial"
>}}) about how to use these sources.
+You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial" >}})
about how to use these sources.
{{< img src="/fig/cdc-flow.png" width="600px" alt="Flink CDC" >}}
## Supported Connectors
-| Connector | Database
| Driver |
-|-----------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------------------|
-| [mongodb-cdc](../mongodb-cdc) | <li> [MongoDB](https://www.mongodb.com):
3.6, 4.x, 5.0
| MongoDB Driver: 4.3.4 |
-| [mysql-cdc](../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](../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](../oracle-cdc) | <li>
[Oracle](https://www.oracle.com/index.html): 11, 12, 19, 21
| Oracle
Driver: 19.3.0.0 |
-| [postgres-cdc](../postgres-cdc) | <li>
[PostgreSQL](https://www.postgresql.org): 9.6, 10, 11, 12, 13, 14
| JDBC
Driver: 42.5.1 |
-| [sqlserver-cdc](../sqlserver-cdc) | <li>
[Sqlserver](https://www.microsoft.com/sql-server): 2012, 2014, 2016, 2017, 2019
| JDBC
Driver: 9.4.1.jre8 |
-| [tidb-cdc](../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](../db2-cdc) | <li>
[Db2](https://www.ibm.com/products/db2): 11.5
| Db2 Driver:
11.5.0.0 |
-| [vitess-cdc](../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
|
MongoDB Driver: 4.3.4 |
+| [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 |
## Supported Flink Versions
The following table shows the version mapping between Flink<sup>®</sup> CDC
Connectors and Flink<sup>®</sup>:
@@ -72,17 +72,17 @@ The following table shows the version mapping between
Flink<sup>®</sup> 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) | ✅ | ✅ | ✅
| ✅ |
-| [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) | ✅ | ❌ | ✅
| ❌ |
+| Connector |
No-lock Read | Parallel Read | Exactly-once Read | Incremental Snapshot Read |
+|----------------------------------------------------------------------------|--------------|---------------|-------------------|---------------------------|
+| [mongodb-cdc]({{< ref "docs/connectors/flink-sources/mongodb-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [mysql-cdc]({{< ref "docs/connectors/flink-sources/mysql-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [oracle-cdc]({{< ref "docs/connectors/flink-sources/oracle-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [postgres-cdc]({{< ref "docs/connectors/flink-sources/postgres-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [sqlserver-cdc]({{< ref "docs/connectors/flink-sources/sqlserver-cdc" >}}) |
✅ | ✅ | ✅ | ✅ |
+| [oceanbase-cdc]({{< ref "docs/connectors/flink-sources/oceanbase-cdc" >}}) |
❌ | ❌ | ❌ | ❌ |
+| [tidb-cdc]({{< ref "docs/connectors/flink-sources/tidb-cdc" >}}) |
✅ | ❌ | ✅ | ❌ |
+| [db2-cdc]({{< ref "docs/connectors/flink-sources/db2-cdc" >}}) |
❌ | ❌ | ✅ | ❌ |
+| [vitess-cdc]({{< ref "docs/connectors/flink-sources/vitess-cdc" >}}) |
✅ | ❌ | ✅ | ❌ |
## Usage for Table/SQL API
@@ -123,7 +123,7 @@ Include following Maven dependency (available through Maven
Central):
```
<dependency>
- <groupId>com.ververica</groupId>
+ <groupId>org.apache.flink</groupId>
<!-- add the dependency matching your database -->
<artifactId>flink-connector-mysql-cdc</artifactId>
<!-- The dependency is available only for stable releases, SNAPSHOT
dependencies need to be built based on master or release branches by yourself.
-->
@@ -133,8 +133,8 @@ Include following Maven dependency (available through Maven
Central):
```java
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
-import com.ververica.cdc.connectors.mysql.source.MySqlSource;
+import org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
public class MySqlBinlogSourceExample {
public static void main(String[] args) throws Exception {
diff --git
a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
b/docs/content/docs/connectors/flink-sources/postgres-cdc.md
similarity index 99%
rename from
docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
rename to docs/content/docs/connectors/flink-sources/postgres-cdc.md
index 4e4bfbf0b..3e54855a4 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/postgres-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/postgres-cdc.md
@@ -1,9 +1,9 @@
---
title: "Postgres"
-weight: 6
+weight: 5
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/postgres-cdc
+- /connectors/flink-sources/postgres-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
b/docs/content/docs/connectors/flink-sources/sqlserver-cdc.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
rename to docs/content/docs/connectors/flink-sources/sqlserver-cdc.md
index e66813c44..abc2779ef 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/sqlserver-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/sqlserver-cdc.md
@@ -1,9 +1,9 @@
---
title: "SQL Server"
-weight: 7
+weight: 4
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/sqlserver-cdc
+- /connectors/flink-sources/sqlserver-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
b/docs/content/docs/connectors/flink-sources/tidb-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
rename to docs/content/docs/connectors/flink-sources/tidb-cdc.md
index f0865859f..6ac2db6ba 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/tidb-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/tidb-cdc.md
@@ -3,7 +3,7 @@ title: "TiDB"
weight: 8
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tidb-cdc
+- /connectors/flink-sources/tidb-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
b/docs/content/docs/connectors/flink-sources/tutorials/_index.md
similarity index 100%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/_index.md
rename to docs/content/docs/connectors/flink-sources/tutorials/_index.md
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
index 6408a9aa5..394a53c27 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.md
+++
b/docs/content/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md
@@ -3,7 +3,7 @@ title: "Building a Real-time Data Lake with Flink CDC"
weight: 998
type: docs
aliases:
--
/connectors/legacy-flink-cdc-sources/tutorials/build-real-time-data-lake-tutorial.html
+- /connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.html
---
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
index a357570bf..276fbd155 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/build-streaming-etl-tutorial.md
+++
b/docs/content/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md
@@ -3,7 +3,7 @@ title: "Building a Streaming ETL with Flink CDC"
weight: 999
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mysql-postgres-tutorial.html
+- /connectors/flink-sources/tutorials/mysql-postgres-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/db2-tutorial.md
similarity index 98%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
rename to docs/content/docs/connectors/flink-sources/tutorials/db2-tutorial.md
index 54e69b7f6..e701a5022 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/db2-tutorial.md
@@ -3,7 +3,7 @@ title: "Db2 Tutorial"
weight: 2
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/db2-tutorial.html
+- /connectors/flink-sources/tutorials/db2-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
similarity index 98%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
index 7f5cb1d59..7f21b91f0 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md
@@ -3,7 +3,7 @@ title: "MongoDB Tutorial"
weight: 1
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.html
+- /connectors/flink-sources/tutorials/mongodb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
index e640b55d0..a9bdc3b98 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md
@@ -3,7 +3,7 @@ title: "OceanBase Tutorial"
weight: 3
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/oceanbase-tutorial.html
+- /connectors/flink-sources/tutorials/oceanbase-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
index 905b20223..2b8943e6d 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/oracle-tutorial.md
@@ -3,7 +3,7 @@ title: "Oracle Tutorial"
weight: 4
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/oracle-tutorial.html
+- /connectors/flink-sources/tutorials/oracle-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
index e506bf20b..95d757527 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/polardbx-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md
@@ -3,7 +3,7 @@ title: "PolarDB-X Tutorial"
weight: 5
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/mongodb-tutorial.html
+- /connectors/flink-sources/tutorials/mongodb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
rename to
docs/content/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
index 9c6dc0e43..84a66fbeb 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md
@@ -3,7 +3,7 @@ title: "SqlServer Tutorial"
weight: 6
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/sqlserver-tutorial.html
+- /connectors/flink-sources/tutorials/sqlserver-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
b/docs/content/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
similarity index 99%
rename from
docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
rename to docs/content/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
index 24d9fecfd..2e628c765 100644
---
a/docs/content/docs/connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.md
+++ b/docs/content/docs/connectors/flink-sources/tutorials/tidb-tutorial.md
@@ -3,7 +3,7 @@ title: "TiDB Tutorial"
weight: 7
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/tutorials/tidb-tutorial.html
+- /connectors/flink-sources/tutorials/tidb-tutorial.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git
a/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
b/docs/content/docs/connectors/flink-sources/vitess-cdc.md
similarity index 99%
rename from docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
rename to docs/content/docs/connectors/flink-sources/vitess-cdc.md
index b589374ce..94bbf1311 100644
--- a/docs/content/docs/connectors/legacy-flink-cdc-sources/vitess-cdc.md
+++ b/docs/content/docs/connectors/flink-sources/vitess-cdc.md
@@ -3,7 +3,7 @@ title: "Vitess"
weight: 10
type: docs
aliases:
-- /connectors/legacy-flink-cdc-sources/vitess-cdc
+- /connectors/flink-sources/vitess-cdc
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
b/docs/content/docs/connectors/pipeline-connectors/_index.md
similarity index 95%
rename from docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
rename to docs/content/docs/connectors/pipeline-connectors/_index.md
index e636a211d..3e611a21b 100644
--- a/docs/content.zh/docs/connectors/legacy-flink-cdc-sources/_index.md
+++ b/docs/content/docs/connectors/pipeline-connectors/_index.md
@@ -1,7 +1,7 @@
---
-title: Legacy CDC Sources
+title: Pipeline Connectors
bookCollapseSection: true
-weight: 5
+weight: 1
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/doris.md
b/docs/content/docs/connectors/pipeline-connectors/doris.md
similarity index 99%
rename from docs/content/docs/connectors/doris.md
rename to docs/content/docs/connectors/pipeline-connectors/doris.md
index a7598bf52..b5048eaf9 100644
--- a/docs/content/docs/connectors/doris.md
+++ b/docs/content/docs/connectors/pipeline-connectors/doris.md
@@ -1,9 +1,9 @@
---
title: "Doris"
-weight: 3
+weight: 5
type: docs
aliases:
-- /connectors/doris
+- /connectors/pipeline-connectors/doris
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/mysql.md
b/docs/content/docs/connectors/pipeline-connectors/mysql.md
similarity index 99%
rename from docs/content/docs/connectors/mysql.md
rename to docs/content/docs/connectors/pipeline-connectors/mysql.md
index 455e22edf..a2971dcf4 100644
--- a/docs/content/docs/connectors/mysql.md
+++ b/docs/content/docs/connectors/pipeline-connectors/mysql.md
@@ -3,7 +3,7 @@ title: "MySQL"
weight: 2
type: docs
aliases:
-- /connectors/mysql
+- /connectors/pipeline-connectors/mysql
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/connectors/overview.md
b/docs/content/docs/connectors/pipeline-connectors/overview.md
similarity index 63%
rename from docs/content/docs/connectors/overview.md
rename to docs/content/docs/connectors/pipeline-connectors/overview.md
index 0eee7bdfa..dea685980 100644
--- a/docs/content/docs/connectors/overview.md
+++ b/docs/content/docs/connectors/pipeline-connectors/overview.md
@@ -3,7 +3,7 @@ title: "Overview"
weight: 1
type: docs
aliases:
- - /connectors/overview
+- /connectors/pipeline-connectors/overview
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -33,11 +33,11 @@ definition.
## Supported Connectors
-| Connector | Supported Type |
External System
|
-|------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| [Apache Doris]({{< ref "docs/connectors/doris" >}}) | Sink | <li>
[Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x
|
-| [MySQL]({{< ref "docs/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 |
-| [StarRocks]({{< ref "docs/connectors/starrocks" >}}) | Sink | <li>
[StarRocks](https://www.starrocks.io/): 2.x, 3.x
|
+| 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
|
+| [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 |
+| [StarRocks]({{< ref "docs/connectors/pipeline-connectors/starrocks" >}}) |
Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x
|
## Develop Your Own Connector
@@ -46,11 +46,4 @@ your own connector to get your external system involved in
Flink CDC pipelines.
Check out [Flink CDC APIs]({{< ref
"docs/developer-guide/understand-flink-cdc-api" >}})
to learn how to develop your own connectors.
-## Legacy Flink CDC Sources
-
-Flink CDC sources introduces before 3.0 are still available as normal Flink
-connector sources. You can find more details in the
-[overview page]({{< ref "docs/connectors/legacy-flink-cdc-sources/overview"
>}})
-of legacy Flink CDC sources.
-
{{< top >}}
diff --git a/docs/content/docs/connectors/starrocks.md
b/docs/content/docs/connectors/pipeline-connectors/starrocks.md
similarity index 99%
rename from docs/content/docs/connectors/starrocks.md
rename to docs/content/docs/connectors/pipeline-connectors/starrocks.md
index 84a4a99d1..dcb8a43f2 100644
--- a/docs/content/docs/connectors/starrocks.md
+++ b/docs/content/docs/connectors/pipeline-connectors/starrocks.md
@@ -1,9 +1,9 @@
---
title: "StarRocks"
-weight: 4
+weight: 6
type: docs
aliases:
-- /connectors/starrocks
+- /connectors/pipeline-connectors/starrocks
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
diff --git a/docs/content/docs/deployment/kubernetes.md
b/docs/content/docs/deployment/kubernetes.md
index 158757276..95539112b 100644
--- a/docs/content/docs/deployment/kubernetes.md
+++ b/docs/content/docs/deployment/kubernetes.md
@@ -48,7 +48,7 @@ If you have problems setting up a Kubernetes cluster, please
take a look at [how
## Session Mode
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
@@ -134,8 +134,8 @@ pipeline:
```
You need to modify the configuration file according to your needs, refer to
connectors more information.
-- [MySQL pipeline connector]({{< ref "docs/connectors/mysql.md" >}})
-- [Apache Doris pipeline connector]({{< ref "docs/connectors/doris.md" >}})
+- [MySQL pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/mysql.md" >}})
+- [Apache Doris pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/doris.md" >}})
Finally, submit job to Flink Standalone cluster using Cli.
diff --git a/docs/content/docs/deployment/standalone.md
b/docs/content/docs/deployment/standalone.md
index dd052bcab..aa30db51e 100644
--- a/docs/content/docs/deployment/standalone.md
+++ b/docs/content/docs/deployment/standalone.md
@@ -32,7 +32,7 @@ You will also run an example Flink CDC job and view it in the
web UI.
## Preparation
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
@@ -111,8 +111,8 @@ pipeline:
```
You need to modify the configuration file according to your needs, refer to
connectors more information.
-- [MySQL pipeline connector]({{< ref "docs/connectors/mysql.md" >}})
-- [Apache Doris pipeline connector]({{< ref "docs/connectors/doris.md" >}})
+- [MySQL pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/mysql.md" >}})
+- [Apache Doris pipeline connector]({{< ref
"docs/connectors/pipeline-connectors/doris.md" >}})
Finally, submit job to Flink Standalone cluster using Cli.
diff --git a/docs/content/docs/deployment/yarn.md
b/docs/content/docs/deployment/yarn.md
index ec9700d89..5f6236a64 100644
--- a/docs/content/docs/deployment/yarn.md
+++ b/docs/content/docs/deployment/yarn.md
@@ -46,7 +46,7 @@ export HADOOP_CLASSPATH=`hadoop classpath`
## Session Mode
Flink runs on all UNIX-like environments, i.e. Linux, Mac OS X, and Cygwin
(for Windows).
-You can refer [overview]({{< ref "docs/connectors/overview" >}}) to check
supported versions and download [the binary
release](https://flink.apache.org/downloads/) of Flink,
+You can refer [overview]({{< ref
"docs/connectors/pipeline-connectors/overview" >}}) to check supported versions
and download [the binary release](https://flink.apache.org/downloads/) of Flink,
then extract the archive:
```bash
