This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 4f881f82d [FLINK-36952][source-connector/mongodb] Fix typos in MongoDB
connector Chinese documentation (#3811)
4f881f82d is described below
commit 4f881f82d4623f07f8175dc4f1604d1b9f270c40
Author: Thorne <[email protected]>
AuthorDate: Wed Dec 25 09:29:06 2024 +0800
[FLINK-36952][source-connector/mongodb] Fix typos in MongoDB connector
Chinese documentation (#3811)
---
docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
index 7f18fdffc..636c229f1 100644
--- a/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
+++ b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
@@ -147,7 +147,7 @@ SELECT * FROM products;
**请注意**
MongoDB 的更改事件记录在消息之前没有更新。因此,我们只能将其转换为 Flink 的 UPSERT 更改日志流。
-upstart 流需要一个唯一的密钥,所以我们必须声明 `_id` 作为主键。
+因为 upsert 流需要唯一键,所以我们必须声明 `_id` 作为主键。
我们不能将其他列声明为主键, 因为删除操作不包含除 `_id` 和 `sharding key` 之外的键和值。
连接器选项
@@ -367,7 +367,7 @@ MongoDB CDC 连接器是一个 Flink Source 连接器,它将首先读取数据
### 启动模式<a name="启动模式" id="002" ></a>
-配置选项```scan.startup.mode```指定 MySQL CDC 使用者的启动模式。有效枚举包括:
+配置选项```scan.startup.mode```指定 MongoDB CDC 消费者的启动模式。有效枚举包括:
- `initial` (默认):在第一次启动时对受监视的数据库表执行初始快照,并继续读取最新的 oplog。
- `latest-offset`:首次启动时,从不对受监视的数据库表执行快照, 连接器仅从 oplog
的结尾处开始读取,这意味着连接器只能读取在连接器启动之后的数据更改。