Skip to content

Commit 8fd28f1

Browse files
authored
[FLINK-34680][cdc][docs] Add overview page for CDC connectors and optimize connector docs
This closes #3160.
1 parent 4d3da26 commit 8fd28f1

File tree

5 files changed

+57
-52
lines changed

5 files changed

+57
-52
lines changed

docs/content/docs/connectors/doris.md

Lines changed: 8 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -24,13 +24,12 @@ specific language governing permissions and limitations
2424
under the License.
2525
-->
2626

27-
# Doris Pipeline Connector
28-
29-
This article introduces of Doris Pipeline Connector
27+
# Doris Connector
3028

29+
This article introduces of Doris Connector
3130

3231
## Example
33-
----------------
32+
3433

3534
```yaml
3635
source:
@@ -50,8 +49,7 @@ pipeline:
5049

5150
```
5251

53-
## Pipeline options
54-
----------------
52+
## Connector Options
5553

5654
<div class="highlight">
5755
<table class="colwidths-auto docutils">
@@ -180,17 +178,16 @@ pipeline:
180178
</tbody>
181179
</table>
182180
</div>
183-
## Data Type Mapping
184181

185-
----------------
182+
## Data Type Mapping
186183

187184
<div class="wy-table-responsive">
188185
<table class="colwidths-auto docutils">
189186
<thead>
190187
<tr>
191-
<th class="text-left" style="width:10%;">CDC type</th>
192-
<th class="text-left" style="width:30%;">Doris type<a href="https://doris.apache.org/docs/dev/sql-manual/sql-reference/Data-Types/BOOLEAN/"></a></th>
193-
<th class="text-left" style="width:60%;">NOTE</th>
188+
<th class="text-left" style="width:10%;">Flink CDC Type</th>
189+
<th class="text-left" style="width:30%;"><a href="https://doris.apache.org/docs/dev/sql-manual/sql-reference/Data-Types/BOOLEAN/">Doris Type</a></th>
190+
<th class="text-left" style="width:60%;">Note</th>
194191
</tr>
195192
</thead>
196193
<tbody>

docs/content/docs/connectors/legacy-flink-cdc-sources/overview.md

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,12 @@ specific language governing permissions and limitations
2424
under the License.
2525
-->
2626

27-
# CDC Connectors for Apache Flink
27+
# Legacy CDC sources for Apache Flink
2828

29-
CDC Connectors for Apache Flink<sup>®</sup> 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).
30-
The CDC Connectors for Apache Flink<sup>®</sup> 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).
29+
Flink CDC sources is a set of source connectors for <a href="https://flink.apache.org/">Apache Flink<sup>®</sup></a>, ingesting changes from different databases using change data capture (CDC).
30+
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).
31+
32+
You can also read [tutorials]({{< ref "docs/connectors/legacy-flink-cdc-sources/tutorials/mysql-postgres-tutorial" >}}) about how to use these sources.
3133

3234
{{< img src="/fig/cdc-flow.png" width="600px" alt="Flink CDC" >}}
3335

docs/content/docs/connectors/mysql.md

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -24,16 +24,15 @@ specific language governing permissions and limitations
2424
under the License.
2525
-->
2626

27-
# MySQL CDC Pipeline Connector
27+
# MySQL Connector
2828

29-
The MySQL CDC Pipeline Connector allows for reading snapshot data and incremental data from MySQL database and provides end-to-end full-database data synchronization capabilities.
30-
This document describes how to setup the MySQL CDC Pipeline connector.
29+
MySQL connector allows reading snapshot data and incremental data from MySQL database and provides end-to-end full-database data synchronization capabilities.
30+
This document describes how to setup the MySQL connector.
3131

3232

33-
How to create Pipeline
34-
----------------
33+
## Example
3534

36-
The pipeline for reading data from MySQL and sink to Doris can be defined as follows:
35+
An example of the pipeline for reading data from MySQL and sink to Doris can be defined as follows:
3736

3837
```yaml
3938
source:
@@ -58,8 +57,7 @@ pipeline:
5857
parallelism: 4
5958
```
6059
61-
Pipeline Connector Options
62-
----------------
60+
## Connector Options
6361
6462
<div class="highlight">
6563
<table class="colwidths-auto docutils">
@@ -245,8 +243,7 @@ Pipeline Connector Options
245243
</table>
246244
</div>
247245
248-
Startup Reading Position
249-
--------
246+
## Startup Reading Position
250247
251248
The config option `scan.startup.mode` specifies the startup mode for MySQL CDC consumer. The valid enumerations are:
252249

@@ -259,16 +256,15 @@ The config option `scan.startup.mode` specifies the startup mode for MySQL CDC c
259256
- `timestamp`: Skip snapshot phase and start reading binlog events from a specific timestamp.
260257

261258

262-
Data Type Mapping
263-
----------------
259+
## Data Type Mapping
264260

265261
<div class="wy-table-responsive">
266262
<table class="colwidths-auto docutils">
267263
<thead>
268264
<tr>
269-
<th class="text-left" style="width:30%;">MySQL type<a href="https://dev.mysql.com/doc/man/8.0/en/data-types.html"></a></th>
270-
<th class="text-left" style="width:10%;">CDC type</th>
271-
<th class="text-left" style="width:60%;">NOTE</th>
265+
<th class="text-left" style="width:30%;"><a href="https://dev.mysql.com/doc/man/8.0/en/data-types.html">MySQL type</a></th>
266+
<th class="text-left" style="width:10%;">Flink CDC type</th>
267+
<th class="text-left" style="width:60%;">Note</th>
272268
</tr>
273269
</thead>
274270
<tbody>

docs/content/docs/connectors/overview.md

Lines changed: 23 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -24,21 +24,33 @@ specific language governing permissions and limitations
2424
under the License.
2525
-->
2626

27-
# Pipeline Connectors Of CDC Streaming ELT Framework
27+
# Connectors
28+
29+
Flink CDC provides several source and sink connectors to interact with external
30+
systems. You can use these connectors out-of-box, by adding released JARs to
31+
your Flink CDC environment, and specifying the connector in your YAML pipeline
32+
definition.
2833

2934
## Supported Connectors
3035

31-
| Connector | Database |
32-
|---------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
33-
| [doris-pipeline](doris-pipeline.md) | <li> [Doris](https://doris.apache.org/): 1.2.x, 2.x.x |
34-
| [mysql-pipeline](mysql-pipeline.md) | <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 |
35-
| [starrocks-pipeline](starrocks-pipeline.md) | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x |
36+
| Connector | Supported Type | External System |
37+
|------------------------------------------------------|----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
38+
| [Apache Doris]({{< ref "docs/connectors/doris" >}}) | Sink | <li> [Apache Doris](https://doris.apache.org/): 1.2.x, 2.x.x |
39+
| [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 |
40+
| [StarRocks]({{< ref "docs/connectors/starrocks" >}}) | Sink | <li> [StarRocks](https://www.starrocks.io/): 2.x, 3.x |
41+
42+
## Develop Your Own Connector
43+
44+
If provided connectors cannot fulfill your requirement, you can always develop
45+
your own connector to get your external system involved in Flink CDC pipelines.
46+
Check out [Flink CDC APIs]({{< ref "docs/developer-guide/understand-flink-cdc-api" >}})
47+
to learn how to develop your own connectors.
3648

37-
## Supported Flink Versions
38-
The following table shows the version mapping between Flink<sup>®</sup> CDC Pipeline and Flink<sup>®</sup>:
49+
## Legacy Flink CDC Sources
3950

40-
| Flink<sup>®</sup> CDC Version | Flink<sup>®</sup> Version |
41-
|:-----------------------------------:|:------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------:|
42-
| <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> |
51+
Flink CDC sources introduces before 3.0 are still available as normal Flink
52+
connector sources. You can find more details in the
53+
[overview page]({{< ref "docs/connectors/legacy-flink-cdc-sources/overview" >}})
54+
of legacy Flink CDC sources.
4355

4456
{{< top >}}

docs/content/docs/connectors/starrocks.md

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -24,17 +24,16 @@ specific language governing permissions and limitations
2424
under the License.
2525
-->
2626

27-
# StarRocks Pipeline Connector
27+
# StarRocks Connector
2828

29-
The StarRocks Pipeline connector can be used as the *Data Sink* of the pipeline, and write data to [StarRocks](https://github.com/StarRocks/starrocks). This document describes how to set up the StarRocks Pipeline connector.
29+
StarRocks connector can be used as the *Data Sink* of the pipeline, and write data to [StarRocks](https://github.com/StarRocks/starrocks). This document describes how to set up the StarRocks connector.
3030

3131
## What can the connector do?
3232
* Create table automatically if not exist
3333
* Schema change synchronization
3434
* Data synchronization
3535

36-
How to create Pipeline
37-
----------------
36+
## Example
3837

3938
The pipeline for reading data from MySQL and sink to StarRocks can be defined as follows:
4039

@@ -62,8 +61,8 @@ pipeline:
6261
parallelism: 2
6362
```
6463
65-
Pipeline Connector Options
66-
----------------
64+
## Connector Options
65+
6766
<div class="highlight">
6867
<table class="colwidths-auto docutils">
6968
<thead>
@@ -220,8 +219,8 @@ Pipeline Connector Options
220219
</table>
221220
</div>
222221

223-
Usage Notes
224-
--------
222+
223+
## Usage Notes
225224

226225
* Only support StarRocks primary key table, so the source table must have primary keys.
227226

@@ -244,15 +243,14 @@ Usage Notes
244243
to write data to StarRocks. You can see [sink documentation](https://github.com/StarRocks/starrocks-connector-for-apache-flink/blob/main/docs/content/connector-sink.md)
245244
for how it works.
246245

247-
Data Type Mapping
248-
----------------
246+
## Data Type Mapping
249247
<div class="wy-table-responsive">
250248
<table class="colwidths-auto docutils">
251249
<thead>
252250
<tr>
253-
<th class="text-left">CDC type</th>
251+
<th class="text-left">Flink CDC type</th>
254252
<th class="text-left">StarRocks type</th>
255-
<th class="text-left" style="width:60%;">NOTE</th>
253+
<th class="text-left" style="width:60%;">Note</th>
256254
</tr>
257255
</thead>
258256
<tbody>

0 commit comments

Comments
 (0)