e-mhui commented on code in PR #775:
URL: https://github.com/apache/inlong-website/pull/775#discussion_r1231947888
##########
i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/mysql-cdc.md:
##########
@@ -114,294 +114,57 @@ TODO: 将在未来支持此功能。
## MySQL Extract 节点参数
-<div class="highlight">
-<table class="colwidths-auto docutils">
- <thead>
- <tr>
- <th class="text-left" style={{width: '10%'}}>参数</th>
- <th class="text-left" style={{width: '8%'}}>是否必须</th>
- <th class="text-left" style={{width: '7%'}}>默认值</th>
- <th class="text-left" style={{width: '10%'}}>数据类型</th>
- <th class="text-left" style={{width: '65%'}}>描述</th>
- </tr>
- </thead>
- <tbody>
- <tr>
- <td>connector</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>指定要使用的连接器，这里应该是 <code>'mysql-cdc-inlong'</code>。</td>
- </tr>
- <tr>
- <td>hostname</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>MySQL 数据库服务器的 IP 地址或主机名。</td>
- </tr>
- <tr>
- <td>username</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>连接到 MySQL 数据库服务器时要使用的 MySQL 用户名称。</td>
- </tr>
- <tr>
- <td>password</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>连接到 MySQL 数据库服务器时使用的密码。</td>
- </tr>
- <tr>
- <td>database-name</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>要监控的 MySQL 服务器的数据库名称。 database-name 还支持正则表达式来监控多个表是否匹配正则表达式。</td>
- </tr>
- <tr>
- <td>table-name</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>要监控的 MySQL 数据库的表名。 table-name 还支持正则表达式来监控多个表是否匹配正则表达式。</td>
- </tr>
- <tr>
- <td>port</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>3306</td>
- <td>Integer</td>
- <td>MySQL 数据库服务器的整数端口号。</td>
- </tr>
- <tr>
- <td>server-id</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>Integer</td>
- <td>此数据库客户端的数字 Id 或数字 Id 范围，数字 Id 语法类似于 '5400'，
- 数字 Id
范围语法类似于“5400-5408”，启用“scan.incremental.snapshot.enabled”时建议使用数字 Id 范围语法。
- 在 MySQL 集群中所有当前运行的数据库进程中，每个 Id 都必须是唯一的。此连接器加入 MySQL 集群
- 作为另一台服务器（具有此唯一 Id），因此它可以读取 Binlog。默认情况下，会生成一个介于 5400 和 6400 之间的随机数，
- 尽管我们建议设置一个明确的值。
- </td>
- </tr>
- <tr>
- <td>scan.incremental.snapshot.enabled</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>true</td>
- <td>Boolean</td>
- <td>增量快照是一种读取表快照的新机制。与旧的快照机制相比，
- 增量快照有很多优点，包括：
- (1) 快照读取时 Source 可以并行，
- (2) Source 可以在快照读取时在 Chunk 粒度上进行检查点，
- (3) Source 在读快照前不需要获取全局读锁（FLUSH TABLES WITH READ LOCK）。
- 如果您希望源代码并行运行，每个并行阅读器都应该有一个唯一的服务器 ID，所以
- 'server-id' 必须是 '5400-6400' 这样的范围，并且范围必须大于并行度。
- 请参阅<a
href="https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#incremental-snapshot-reading";>增量快照阅读</a>部分了解更多详细信息。
- </td>
- </tr>
- <tr>
- <td>scan.incremental.snapshot.chunk.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>8096</td>
- <td>Integer</td>
- <td>表快照的块大小（行数），读取表的快照时，表的快照被分成多个块。</td>
- </tr>
- <tr>
- <td>scan.snapshot.fetch.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>1024</td>
- <td>Integer</td>
- <td>读取表快照时每次轮询的最大获取大小。</td>
- </tr>
- <tr>
- <td>scan.startup.mode</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>initial</td>
- <td>String</td>
- <td>MySQL CDC 消费者的可选启动模式，有效枚举为"initial"
- 和"latest-offset"。
- 请参阅<a
href="https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#startup-reading-position";>启动阅读位置</a>部分了解更多详细信息。</td>
- </tr>
- <tr>
- <td>server-time-zone</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>UTC</td>
- <td>String</td>
- <td>数据库服务器中的会话时区，例如"Asia/Shanghai"。
- 它控制 MYSQL 中的 TIMESTAMP 类型如何转换为 STRING。
- 查看更多<a
href="https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-temporal-types";>这里</a>。</td>
- </tr>
- <tr>
- <td>debezium.min.row.
- count.to.stream.result</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>1000</td>
- <td>Integer</td>
- <td>在快照操作期间，连接器将查询每个包含的表，以便为该表中的所有行生成读取事件。此参数确定 MySQL
连接是否会将表的所有结果拉入内存（速度很快但需要大量内存），或者是否将结果改为流式传输（可能较慢，但适用于非常大的表）。该值指定在连接器流式传输结果之前表必须包含的最小行数，默认为
1,000。将此参数设置为'0'以跳过所有表大小检查并始终在快照期间流式传输所有结果。</td>
- </tr>
- <tr>
- <td>connect.timeout</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>30s</td>
- <td>Duration</td>
- <td>连接器在尝试连接到 MySQL 数据库服务器后在超时之前应等待的最长时间。</td>
- </tr>
- <tr>
- <td>connect.max-retries</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>3</td>
- <td>Integer</td>
- <td>连接器应重试以建立 MySQL 数据库服务器连接的最大重试次数。</td>
- </tr>
- <tr>
- <td>connection.pool.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>20</td>
- <td>Integer</td>
- <td>连接池大小。</td>
- </tr>
- <tr>
- <td>jdbc.properties.*</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>20</td>
- <td>String</td>
- <td>传递自定义 JDBC URL 属性的选项。用户可以传递自定义属性，例如 'jdbc.properties.useSSL' =
'false'。</td>
- </tr>
- <tr>
- <td>heartbeat.interval</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>30s</td>
- <td>Duration</td>
- <td>发送心跳事件的时间间隔，用于跟踪最新可用的 Binlog 偏移量。</td>
- </tr>
- <tr>
- <td>append-mode</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>是否仅支持 Append，如果为 'true'，MySQL Extract Node 会将所有 Upsert 流转换为
Append 流，以支持不支持 Upsert 流的下游场景。</td>
- </tr>
- <tr>
- <td>migrate-all</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>是否是全库迁移场景，如果为 'true'，MySQL Extract Node 则将表的物理字段和其他元字段压缩成 'json'
- 格式的特殊 'data' 元字段, 目前支持两种 data 格式, 如果需要 'canal json' 格式的数据，
- 则使用 'data_canal' 元数据字段，如果需要使用 'debezium json' 格式的数据则使用
'data_debezium' 元数据字段。</td>
- </tr>
- <tr>
- <td>row-kinds-filtered</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>需要保留的特定的操作类型，其中 +U 对应更新前的数据，-U 对应更新后的数据，+I 对应
- 插入的数据（存量数据为插入类型的数据），-D 代表删除的数据， 如需保留多个操作类型则使用 & 连接。
- 举例 +I&-D，connector 只会输出插入以及删除的数据，更新的数据则不会输出。</td>
- </tr>
- <tr>
- <td>debezium.*</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>将 Debezium 的属性传递给用于从 MySQL 服务器捕获数据更改的 Debezium Embedded Engine。
- 例如：<code>'debezium.snapshot.mode' = 'never'</code>。
- 详细了解 <a
href="https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-connector-properties";>Debezium
的 MySQL 连接器属性。</a></td>
- </tr>
- <tr>
- <td>inlong.metric.labels</td>
- <td>可选</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>inlong metric
的标签值，该值的构成为groupId=[groupId]&streamId=[streamId]&nodeId=[nodeId]。</td>
- </tr>
- </tbody>
-</table>
-</div>
+| 参数 | 是否必须 | 默认值 | 数据类型 | 描述 |
+| --- | --- | --- | --- | --- |
+| connector | required | (none) | String | 指定要使用的连接器，这里应该是
`'mysql-cdc-inlong'`。 |
+| hostname | required | (none) | String | MySQL 数据库服务器的 IP 地址或主机名。 |
+| username | required | (none) | String | 连接到 MySQL 数据库服务器时要使用的 MySQL 用户名称。 |
+| password | required | (none) | String | 连接到 MySQL 数据库服务器时使用的密码。 |
+| database-name | required | (none) | String | 要监控的 MySQL 服务器的数据库名称。
database-name 还支持正则表达式来监控多个表是否匹配正则表达式。 |
+| table-name | required | (none) | String | 要监控的 MySQL 数据库的表名。 table-name
还支持正则表达式来监控多个表是否匹配正则表达式。 |
+| port | optional | 3306 | Integer | MySQL 数据库服务器的整数端口号。 |
+| server-id | optional | (none) | Integer | 此数据库客户端的数字 Id 或数字 Id 范围，数字 Id
语法类似于 '5400'， 数字 Id
范围语法类似于“5400-5408”，启用“scan.incremental.snapshot.enabled”时建议使用数字 Id 范围语法。 在
MySQL 集群中所有当前运行的数据库进程中，每个 Id 都必须是唯一的。此连接器加入 MySQL 集群 作为另一台服务器（具有此唯一 Id），因此它可以读取
Binlog。默认情况下，会生成一个介于 5400 和 6400 之间的随机数， 尽管我们建议设置一个明确的值。 |
+| scan.incremental.snapshot.enabled | optional | true | Boolean |
增量快照是一种读取表快照的新机制。与旧的快照机制相比， 增量快照有很多优点，包括： (1) 快照读取时 Source 可以并行， (2) Source
可以在快照读取时在 Chunk 粒度上进行检查点， (3) Source 在读快照前不需要获取全局读锁（FLUSH TABLES WITH READ
LOCK）。 如果您希望源代码并行运行，每个并行阅读器都应该有一个唯一的服务器 ID，所以 'server-id' 必须是 '5400-6400'
这样的范围，并且范围必须大于并行度。
请参阅[增量快照阅读](https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#incremental-snapshot-reading)部分了解更多详细信息。
|
+| scan.incremental.snapshot.chunk.size | optional | 8096 | Integer |
表快照的块大小（行数），读取表的快照时，表的快照被分成多个块。 |
+| scan.snapshot.fetch.size | optional | 1024 | Integer | 读取表快照时每次轮询的最大获取大小。 |
+| scan.startup.mode | optional | initial | String | MySQL CDC
消费者的可选启动模式，有效枚举为"initial" 和"latest-offset"。 请参阅[启动阅读位置](#启动模式)部分了解更多详细信息。 |
Review Comment:
Thanks, it has done.
##########
i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/mysql-cdc.md:
##########
@@ -114,294 +114,57 @@ TODO: 将在未来支持此功能。
## MySQL Extract 节点参数
-<div class="highlight">
-<table class="colwidths-auto docutils">
- <thead>
- <tr>
- <th class="text-left" style={{width: '10%'}}>参数</th>
- <th class="text-left" style={{width: '8%'}}>是否必须</th>
- <th class="text-left" style={{width: '7%'}}>默认值</th>
- <th class="text-left" style={{width: '10%'}}>数据类型</th>
- <th class="text-left" style={{width: '65%'}}>描述</th>
- </tr>
- </thead>
- <tbody>
- <tr>
- <td>connector</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>指定要使用的连接器，这里应该是 <code>'mysql-cdc-inlong'</code>。</td>
- </tr>
- <tr>
- <td>hostname</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>MySQL 数据库服务器的 IP 地址或主机名。</td>
- </tr>
- <tr>
- <td>username</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>连接到 MySQL 数据库服务器时要使用的 MySQL 用户名称。</td>
- </tr>
- <tr>
- <td>password</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>连接到 MySQL 数据库服务器时使用的密码。</td>
- </tr>
- <tr>
- <td>database-name</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>要监控的 MySQL 服务器的数据库名称。 database-name 还支持正则表达式来监控多个表是否匹配正则表达式。</td>
- </tr>
- <tr>
- <td>table-name</td>
- <td>required</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>要监控的 MySQL 数据库的表名。 table-name 还支持正则表达式来监控多个表是否匹配正则表达式。</td>
- </tr>
- <tr>
- <td>port</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>3306</td>
- <td>Integer</td>
- <td>MySQL 数据库服务器的整数端口号。</td>
- </tr>
- <tr>
- <td>server-id</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>Integer</td>
- <td>此数据库客户端的数字 Id 或数字 Id 范围，数字 Id 语法类似于 '5400'，
- 数字 Id
范围语法类似于“5400-5408”，启用“scan.incremental.snapshot.enabled”时建议使用数字 Id 范围语法。
- 在 MySQL 集群中所有当前运行的数据库进程中，每个 Id 都必须是唯一的。此连接器加入 MySQL 集群
- 作为另一台服务器（具有此唯一 Id），因此它可以读取 Binlog。默认情况下，会生成一个介于 5400 和 6400 之间的随机数，
- 尽管我们建议设置一个明确的值。
- </td>
- </tr>
- <tr>
- <td>scan.incremental.snapshot.enabled</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>true</td>
- <td>Boolean</td>
- <td>增量快照是一种读取表快照的新机制。与旧的快照机制相比，
- 增量快照有很多优点，包括：
- (1) 快照读取时 Source 可以并行，
- (2) Source 可以在快照读取时在 Chunk 粒度上进行检查点，
- (3) Source 在读快照前不需要获取全局读锁（FLUSH TABLES WITH READ LOCK）。
- 如果您希望源代码并行运行，每个并行阅读器都应该有一个唯一的服务器 ID，所以
- 'server-id' 必须是 '5400-6400' 这样的范围，并且范围必须大于并行度。
- 请参阅<a
href="https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#incremental-snapshot-reading";>增量快照阅读</a>部分了解更多详细信息。
- </td>
- </tr>
- <tr>
- <td>scan.incremental.snapshot.chunk.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>8096</td>
- <td>Integer</td>
- <td>表快照的块大小（行数），读取表的快照时，表的快照被分成多个块。</td>
- </tr>
- <tr>
- <td>scan.snapshot.fetch.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>1024</td>
- <td>Integer</td>
- <td>读取表快照时每次轮询的最大获取大小。</td>
- </tr>
- <tr>
- <td>scan.startup.mode</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>initial</td>
- <td>String</td>
- <td>MySQL CDC 消费者的可选启动模式，有效枚举为"initial"
- 和"latest-offset"。
- 请参阅<a
href="https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#startup-reading-position";>启动阅读位置</a>部分了解更多详细信息。</td>
- </tr>
- <tr>
- <td>server-time-zone</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>UTC</td>
- <td>String</td>
- <td>数据库服务器中的会话时区，例如"Asia/Shanghai"。
- 它控制 MYSQL 中的 TIMESTAMP 类型如何转换为 STRING。
- 查看更多<a
href="https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-temporal-types";>这里</a>。</td>
- </tr>
- <tr>
- <td>debezium.min.row.
- count.to.stream.result</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>1000</td>
- <td>Integer</td>
- <td>在快照操作期间，连接器将查询每个包含的表，以便为该表中的所有行生成读取事件。此参数确定 MySQL
连接是否会将表的所有结果拉入内存（速度很快但需要大量内存），或者是否将结果改为流式传输（可能较慢，但适用于非常大的表）。该值指定在连接器流式传输结果之前表必须包含的最小行数，默认为
1,000。将此参数设置为'0'以跳过所有表大小检查并始终在快照期间流式传输所有结果。</td>
- </tr>
- <tr>
- <td>connect.timeout</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>30s</td>
- <td>Duration</td>
- <td>连接器在尝试连接到 MySQL 数据库服务器后在超时之前应等待的最长时间。</td>
- </tr>
- <tr>
- <td>connect.max-retries</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>3</td>
- <td>Integer</td>
- <td>连接器应重试以建立 MySQL 数据库服务器连接的最大重试次数。</td>
- </tr>
- <tr>
- <td>connection.pool.size</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>20</td>
- <td>Integer</td>
- <td>连接池大小。</td>
- </tr>
- <tr>
- <td>jdbc.properties.*</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>20</td>
- <td>String</td>
- <td>传递自定义 JDBC URL 属性的选项。用户可以传递自定义属性，例如 'jdbc.properties.useSSL' =
'false'。</td>
- </tr>
- <tr>
- <td>heartbeat.interval</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>30s</td>
- <td>Duration</td>
- <td>发送心跳事件的时间间隔，用于跟踪最新可用的 Binlog 偏移量。</td>
- </tr>
- <tr>
- <td>append-mode</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>是否仅支持 Append，如果为 'true'，MySQL Extract Node 会将所有 Upsert 流转换为
Append 流，以支持不支持 Upsert 流的下游场景。</td>
- </tr>
- <tr>
- <td>migrate-all</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>是否是全库迁移场景，如果为 'true'，MySQL Extract Node 则将表的物理字段和其他元字段压缩成 'json'
- 格式的特殊 'data' 元字段, 目前支持两种 data 格式, 如果需要 'canal json' 格式的数据，
- 则使用 'data_canal' 元数据字段，如果需要使用 'debezium json' 格式的数据则使用
'data_debezium' 元数据字段。</td>
- </tr>
- <tr>
- <td>row-kinds-filtered</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>false</td>
- <td>Boolean</td>
- <td>需要保留的特定的操作类型，其中 +U 对应更新前的数据，-U 对应更新后的数据，+I 对应
- 插入的数据（存量数据为插入类型的数据），-D 代表删除的数据， 如需保留多个操作类型则使用 & 连接。
- 举例 +I&-D，connector 只会输出插入以及删除的数据，更新的数据则不会输出。</td>
- </tr>
- <tr>
- <td>debezium.*</td>
- <td>optional</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>将 Debezium 的属性传递给用于从 MySQL 服务器捕获数据更改的 Debezium Embedded Engine。
- 例如：<code>'debezium.snapshot.mode' = 'never'</code>。
- 详细了解 <a
href="https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-connector-properties";>Debezium
的 MySQL 连接器属性。</a></td>
- </tr>
- <tr>
- <td>inlong.metric.labels</td>
- <td>可选</td>
- <td style={{wordWrap: 'break-word'}}>(none)</td>
- <td>String</td>
- <td>inlong metric
的标签值，该值的构成为groupId=[groupId]&streamId=[streamId]&nodeId=[nodeId]。</td>
- </tr>
- </tbody>
-</table>
-</div>
+| 参数 | 是否必须 | 默认值 | 数据类型 | 描述 |
+| --- | --- | --- | --- | --- |
+| connector | required | (none) | String | 指定要使用的连接器，这里应该是
`'mysql-cdc-inlong'`。 |
+| hostname | required | (none) | String | MySQL 数据库服务器的 IP 地址或主机名。 |
+| username | required | (none) | String | 连接到 MySQL 数据库服务器时要使用的 MySQL 用户名称。 |
+| password | required | (none) | String | 连接到 MySQL 数据库服务器时使用的密码。 |
+| database-name | required | (none) | String | 要监控的 MySQL 服务器的数据库名称。
database-name 还支持正则表达式来监控多个表是否匹配正则表达式。 |
+| table-name | required | (none) | String | 要监控的 MySQL 数据库的表名。 table-name
还支持正则表达式来监控多个表是否匹配正则表达式。 |
+| port | optional | 3306 | Integer | MySQL 数据库服务器的整数端口号。 |
+| server-id | optional | (none) | Integer | 此数据库客户端的数字 Id 或数字 Id 范围，数字 Id
语法类似于 '5400'， 数字 Id
范围语法类似于“5400-5408”，启用“scan.incremental.snapshot.enabled”时建议使用数字 Id 范围语法。 在
MySQL 集群中所有当前运行的数据库进程中，每个 Id 都必须是唯一的。此连接器加入 MySQL 集群 作为另一台服务器（具有此唯一 Id），因此它可以读取
Binlog。默认情况下，会生成一个介于 5400 和 6400 之间的随机数， 尽管我们建议设置一个明确的值。 |
+| scan.incremental.snapshot.enabled | optional | true | Boolean |
增量快照是一种读取表快照的新机制。与旧的快照机制相比， 增量快照有很多优点，包括： (1) 快照读取时 Source 可以并行， (2) Source
可以在快照读取时在 Chunk 粒度上进行检查点， (3) Source 在读快照前不需要获取全局读锁（FLUSH TABLES WITH READ
LOCK）。 如果您希望源代码并行运行，每个并行阅读器都应该有一个唯一的服务器 ID，所以 'server-id' 必须是 '5400-6400'
这样的范围，并且范围必须大于并行度。
请参阅[增量快照阅读](https://ververica.github.io/flink-cdc-connectors/release-2.2/content/connectors/mysql-cdc.html#incremental-snapshot-reading)部分了解更多详细信息。
|
+| scan.incremental.snapshot.chunk.size | optional | 8096 | Integer |
表快照的块大小（行数），读取表的快照时，表的快照被分成多个块。 |
+| scan.snapshot.fetch.size | optional | 1024 | Integer | 读取表快照时每次轮询的最大获取大小。 |
+| scan.startup.mode | optional | initial | String | MySQL CDC
消费者的可选启动模式，有效枚举为"initial" 和"latest-offset"。 请参阅[启动阅读位置](#启动模式)部分了解更多详细信息。 |
+| scan.startup.specific-offset.file | optional | (none) | String | 在
"specific-offset" 启动模式下，启动位点的 binlog 文件名。|
+| scan.startup.specific-offset.pos| optional | (none) | Long | 在
"specific-offset" 启动模式下，启动位点的 binlog 文件位置。|
+| scan.startup.specific-offset.gtid-set | optional | (none) | String | 在
"specific-offset" 启动模式下，启动位点的 GTID 集合。|
+| scan.startup.specific-offset.skip-events | optional | (none) | Long |
在指定的启动位点后需要跳过的事件数量。|
+| scan.startup.specific-offset.skip-rows | optional | (none) | Long |
在指定的启动位点后需要跳过的数据行数量。|
+| server-time-zone | optional | UTC | String | 数据库服务器中的会话时区，例如"Asia/Shanghai"。
它控制 MYSQL 中的 TIMESTAMP 类型如何转换为 STRING。
查看更多[这里](https://debezium.io/documentation/reference/1.5/connectors/mysql.html#mysql-temporal-types)。
|
Review Comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
