|
|
|
@ -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 的结尾处开始读取,这意味着连接器只能读取在连接器启动之后的数据更改。
|
|
|
|
|