启动属性

startup.mode

类型：字符串


描述：指定当没有可用的源偏移时，Connector应如何启动。恢复变更流需要恢复令牌，Connector将从源偏移获取该令牌。如果没有可用的源偏移，则Connector可能会忽略全部或部分现有源数据，或者可能会先复制所有现有源数据，然后继续处理新数据。如果为

startup.mode=latest

startup.mode=timestampstartup.mode.timestamp.*，则Connector将忽略所有现有源数据。如果为timestamp latest

startup.mode=copy_existing，Connector将激活 属性。如果未配置任何属性，则 相当于 。如果为 ，Connector会将所有现有源数据复制到变更流事件。此设置相当于已弃用的设置copy.existing=true 。

如果任何系统在源Connector从数据库转换现有数据时更改数据库中的数据， MongoDB可能会生成重复的变更流事件以反映最新更改。由于数据复制所依赖的变更流事件是幂等的，因此复制的数据最终是一致的，符合“至少一次”交付保证。

默认值：latest
接受值：latest 、timestamp 、copy_existing

startup.mode.timestamp.start.at.operation.time

类型：字符串

描述：仅在
startup.mode=timestamp

时才启动。指定变更流的点。要学习；了解有关变更流参数的更多信息，请参阅MongoDB手册中的 $changeStream（聚合）。默认值：

""
接受的值：

• 自纪元以来的整数秒数（十进制格式）（例如，30）

• ISO-8601 格式的瞬间，精度为一秒（例如，1970-01-01T00:00:30Z）

• 规范扩展 JSON (v2) 格式的 BSON 时间戳（例如 {"$timestamp": {"t": 30, "i": 0}}）

startup.mode.copy.existing.namespace.regex

类型：字符串


描述：Connector用于匹配要从中复制数据的命名空间的正则表达式。命名空间描述由句点分隔的MongoDB 数据库名称和集合（示例 ）。示例，以下正则表达式设置匹配databaseName.collectionName

stats数据库中以“page”开头的集合：

startup.mode.copy.existing.namespace.regex=stats\.page.*

\上述示例中的 字符对正则表达式中其后的. 字符进行转义。有关如何构建正则表达式的更多信息，请参阅Java API文档中的模式。默认值：

""
接受的值：有效的正则表达式

startup.mode.copy.existing.pipeline

类型：字符串


描述：Connector在复制现有数据时运行的管道操作的内联大量。您可以使用此设置来过滤源集合，并改进复制进程中索引的使用。示例，以下设置使用

$match聚合操作符符指示Connector仅复制包含值为 closed的false 字段的文档。

startup.mode.copy.existing.pipeline=[ { "$match": { "closed": "false" } } ]

""
默认值： 接受值：有效聚合管道阶段

startup.mode.copy.existing.max.threads

类型：int

描述：Connector可用于复制数据的最大线程数。默认值：环境中可用的处理器数量



接受的值：整数

startup.mode.copy.existing.queue.size

类型：int


描述：Connector在复制数据时可以使用的队列大小。默认值：

16000
接受值：整数

startup.mode.copy.existing.allow.disk.use

类型：布尔值 描述：设立为


true时，Connector使用临时磁盘存储来复制现有聚合。默认值：

true
接受值：true 或false