@@ -35,7 +35,7 @@ MySQL CDC 连接器允许从 MySQL 数据库读取快照数据和增量数据。
35
35
配置 MySQL 服务器
36
36
----------------
37
37
38
- 您必须定义一个 MySQL 用户,该用户对 MySQL CDC 连接器监视的所有数据库都应该具有所需的权限。
38
+ 你必须定义一个 MySQL 用户,该用户对 MySQL CDC 连接器监视的所有数据库都应该具有所需的权限。
39
39
40
40
1 . 创建 MySQL 用户:
41
41
@@ -192,7 +192,7 @@ Flink SQL> SELECT * FROM orders;
192
192
(3)在快照读取之前,Source 不需要数据库锁权限。
193
193
如果希望 Source 并行运行,则每个并行 Readers 都应该具有唯一的 Server id,所以
194
194
Server id 必须是类似 `5400-6400` 的范围,并且该范围必须大于并行度。
195
- 请查阅 <a href="#增量快照读取 ">增量快照读取</a> 章节了解更多详细信息。
195
+ 请查阅 <a href="#a-name-id-001-a ">增量快照读取</a> 章节了解更多详细信息。
196
196
</td>
197
197
</tr>
198
198
<tr>
@@ -216,7 +216,7 @@ Flink SQL> SELECT * FROM orders;
216
216
<td>String</td>
217
217
<td> MySQL CDC 消费者可选的启动模式,
218
218
合法的模式为 "initial" 和 "latest-offset"。
219
- 请查阅 <a href="#启动模式 ">启动模式</a> 章节了解更多详细信息。</td>
219
+ 请查阅 <a href="#a-name-id-002-a ">启动模式</a> 章节了解更多详细信息。</td>
220
220
</tr>
221
221
<tr>
222
222
<td>server-time-zone</td>
@@ -343,7 +343,7 @@ CREATE TABLE products (
343
343
支持的特性
344
344
--------
345
345
346
- ### 增量快照读取
346
+ ### 增量快照读取< a name = " 增量快照读取 " id = " 001 " ></ a >
347
347
348
348
增量快照读取是一种读取表快照的新机制。与旧的快照机制相比,增量快照具有许多优点,包括:
349
349
* (1)在快照读取期间,Source 支持并发读取,
@@ -462,14 +462,14 @@ MySQL CDC Source 使用主键列将表划分为多个分片(chunk)。 默认
462
462
MySQL CDC 连接器是一个 Flink Source 连接器,它将首先读取表快照块,然后继续读取 binlog,
463
463
无论是在快照阶段还是读取 binlog 阶段,MySQL CDC 连接器都会在处理时** 准确读取数据** ,即使任务出现了故障。
464
464
465
- ### 启动模式
465
+ ### 启动模式< a name = " 启动模式 " id = " 002 " ></ a >
466
466
467
467
配置选项``` scan.startup.mode ``` 指定 MySQL CDC 使用者的启动模式。有效枚举包括:
468
468
469
469
- ` initial ` (默认):在第一次启动时对受监视的数据库表执行初始快照,并继续读取最新的 binlog。
470
470
- ` latest-offset ` : 首次启动时,从不对受监视的数据库表执行快照, 连接器仅从 binlog 的结尾处开始读取,这意味着连接器只能读取在连接器启动之后的数据更改。
471
471
472
- _ Note: 扫描启动机制的模式选项依赖于 Debezium 的快照模式配置。所以请不要同时使用它们。如果您同时指定了 ` scan.startup.mode ` 和` debezium.snapshot.mode ` 选项在表DDL中,它可能会使` scan.startup.mode ` 不起作用。_
472
+ _ Note: 扫描启动机制的模式选项依赖于 Debezium 的快照模式配置。所以请不要同时使用它们。如果你同时指定了 ` scan.startup.mode ` 和` debezium.snapshot.mode ` 选项在表DDL中,它可能会使` scan.startup.mode ` 不起作用。_
473
473
474
474
### DataStream Source
475
475
@@ -511,7 +511,7 @@ public class MySqlSourceExample {
511
511
512
512
### 动态加表
513
513
514
- 扫描新添加的表功能使您可以添加新表到正在运行的作业中 ,新添加的表将首先读取其快照数据,然后自动读取其变更日志。
514
+ 扫描新添加的表功能使你可以添加新表到正在运行的作业中 ,新添加的表将首先读取其快照数据,然后自动读取其变更日志。
515
515
516
516
想象一下这个场景:一开始, Flink 作业监控表 ` [product, user, address] ` , 但几天后,我们希望这个作业还可以监控表 ` [order, custom] ` ,这些表包含历史数据,我们需要作业仍然可以复用作业的已有状态,动态加表功能可以优雅地解决此问题。
517
517
@@ -807,14 +807,14 @@ $ ./bin/flink run \
807
807
</td>
808
808
<td>
809
809
MySQL 中的空间数据类型将转换为具有固定 Json 格式的字符串。
810
- 请参考 <a href="# 空间数据类型映射">MySQL 空间数据类型映射</a> 章节了解更多详细信息。
810
+ 请参考 MySQL <a href="#a-name-id-003-a"> 空间数据类型映射</a> 章节了解更多详细信息。
811
811
</td>
812
812
</tr>
813
813
</tbody>
814
814
</table >
815
815
</div >
816
816
817
- ### 空间数据类型映射
817
+ ### 空间数据类型映射< a name = " 空间数据类型映射 " id = " 003 " ></ a >
818
818
819
819
MySQL中除` GEOMETRYCOLLECTION ` 之外的空间数据类型都会转换为 Json 字符串,格式固定,如:<br >
820
820
``` json
0 commit comments