变更流属性
概述
使用以下配置设置来指定与 MongoDB Kafka 源连接器一起工作时更改流的聚合管道和更改流游标的读取偏好。
有关按类别组织的源连接器配置设置的列表，请参阅源连接器配置属性指南.
设置
名称 | 描述 | |
|---|---|---|
pipeline | 类型: 字符串 描述 要运行在更改流中的聚合管道数组。您必须为此设置配置更改流事件文档，而不是 fullDocument 字段。例如 有关更多示例，请参阅 默认值: "[]"可接受值: 有效的聚合管道阶段 | |
change.stream.full.document | 类型: 字符串 描述 确定更改流在更新操作中返回的值。 默认设置返回原始文档和更新文档之间的差异。 updateLookup 设置返回原始文档和更新文档之间的差异，以及更新后的整个文档的副本，该副本在更新后的一个 时间点。whenAvailable 设置返回可用的更新文档。required 设置返回更新文档，如果不可用，则引发错误。有关此更改流选项如何工作的更多信息，请参阅 MongoDB 手册中的更新操作的全文档查找 默认值: ""可接受值: ""、"updateLookup"、"whenAvailable" 或 "required" | |
change.stream.full.document.before.change | 类型: 字符串 描述 配置更改流在更新操作中返回的文档预图像。对于复制现有数据时发布的源记录，预图像不可用，并且预图像配置对复制没有影响。 要了解如何配置集合以启用预图像，请参阅 MongoDB 手册中的 带有文档预和后图像的更改流 默认设置抑制文档预图像。 whenAvailable 设置在可用的前提下返回文档的前映像，在它被替换、更新或删除之前。required 设置在不可用时返回文档的前映像并引发错误。默认值: ""接受值: "" 或 "whenAvailable" 或 "required" | |
publish.full.document.only | 类型：布尔值 描述 是否仅从任何更新事件产生的更改流事件文档中返回 fullDocument 字段。该 fullDocument 字段包含更新文档的最新版本。要了解更多关于 fullDocument 字段的信息，请参阅服务器手册中的 更新事件。当设置为 true 时，连接器覆盖 change.stream.full.document 设置并将其设置为 updateLookup，以便 fullDocument 字段包含更新文档。默认值： false接受值: true 或 false | |
publish.full.document.only.tombstone.on.delete | 类型：布尔值 描述 在删除文档时是否返回墓碑事件。墓碑事件包含已删除文档的键，其值为 null。此设置仅在 publish.full.document.only 为 true 时适用。默认值： false接受值: true 或 false | |
change.stream.document.key.as.key | 类型：布尔值 描述 如果存在文档键，是否使用文档键作为源记录键。 当设置为 true 时，连接器将删除文档的键添加到墓碑事件中。当设置为 false 时，连接器使用恢复令牌作为墓碑事件的源键。默认值： true接受值: true 或 false | |
collation | ||
batch.size | 类型：整数 描述 更改流游标批处理大小。 默认值： 0接受值: 一个整数 | |
poll.await.time.ms | 类型：长整数 描述 服务器在返回空批处理之前等待新数据更改报告给更改流游标的最大毫秒数。 默认值： 5000接受值: 一个整数 | |
poll.max.batch.size | 类型：整数 描述 在轮询更改流游标以获取新数据时，每次读取的文档最大数量。您可以使用此设置来限制连接器内部缓冲的数据量。 默认值： 1000接受值: 一个整数 |