File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
docs/content.zh/docs/connectors/flink-sources Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -147,7 +147,7 @@ SELECT * FROM products;
147
147
** 请注意**
148
148
149
149
MongoDB 的更改事件记录在消息之前没有更新。因此,我们只能将其转换为 Flink 的 UPSERT 更改日志流。
150
- upstart 流需要一个唯一的密钥 ,所以我们必须声明 ` _id ` 作为主键。
150
+ 因为 upsert 流需要唯一键 ,所以我们必须声明 ` _id ` 作为主键。
151
151
我们不能将其他列声明为主键, 因为删除操作不包含除 ` _id ` 和 ` sharding key ` 之外的键和值。
152
152
153
153
连接器选项
@@ -367,7 +367,7 @@ MongoDB CDC 连接器是一个 Flink Source 连接器,它将首先读取数据
367
367
368
368
### 启动模式<a name =" 启动模式 " id =" 002 " ></a >
369
369
370
- 配置选项``` scan.startup.mode ``` 指定 MySQL CDC 使用者的启动模式 。有效枚举包括:
370
+ 配置选项``` scan.startup.mode ``` 指定 MongoDB CDC 消费者的启动模式 。有效枚举包括:
371
371
372
372
- ` initial ` (默认):在第一次启动时对受监视的数据库表执行初始快照,并继续读取最新的 oplog。
373
373
- ` latest-offset ` :首次启动时,从不对受监视的数据库表执行快照, 连接器仅从 oplog 的结尾处开始读取,这意味着连接器只能读取在连接器启动之后的数据更改。
You can’t perform that action at this time.
0 commit comments