Overview
使用以下配置设置来配置 MongoDB Kafka Source 连接器的启动,以将 MongoDB 集合转换为变更流事件。
提示
有关使用复制现有功能的示例,请参阅复制现有数据用法示例。
有关按类别排列的 Source 连接器配置设置列表,请参阅 Source 连接器配置属性指南。
设置
名称 | 说明 | |
|---|---|---|
startup.mode | 类型: string 如果任何系统在源Connector从数据库转换现有数据时更改数据库中的数据, MongoDB可能会生成重复的变更流事件以反映最新更改。由于数据复制所依赖的变更流事件是幂等的,因此复制的数据最终是一致的,符合“至少一次”交付保证。 默认: | |
startup.mode.timestamp.start.at.operation.time | Type: string
| |
startup.mode.copy.existing.namespace.regex | 类型: string 上述示例中的 | |
startup.mode.copy.existing.pipeline | Type: string 默认: | |
startup.mode.copy.existing.max.threads | 类型:int | |
startup.mode.copy.existing.queue.size | 类型:int | |
startup.mode.copy.existing.allow.disk.use | 类型: 布尔值 |