对于 AI 代理:可在 https://www.mongodb.com/zh-cn/docs/llms.txt 获取文档索引—通过在任何 URL 路径后添加 .md 可获取所有页面的 Markdown 版本。
Docs 菜单

变更流属性

使用 MongoDB Kafka 源连接器时,使用以下配置设置指定变更流的聚合管道和变更流游标的读取偏好。

有关按类别排列的 Source 连接器配置设置列表,请参阅 Source 连接器配置属性指南。

名称
说明

管道

类型:字符串


描述:要在变更流中运行的聚合管道大量。您必须为变更流事件文档而不是 字段配置此设置。示例:fullDocument

[{"$match": { "$and": [{"operationType": "insert"}, {"fullDocument.eventId": 1404 }] } }]

有关更多示例,请参阅:

"[]"
默认值: 接受的值:有效的聚合管道阶段

change.stream.full.document

类型:字符串 描述:确定变更流在更新操作中返回的值。默认设置返回原始文档和更新文档之间的差异。


设置返回原始文档和更新文档之间的差异以及更新后某个时间点的整个更新文档的副本。 设置会返回更新的文档(如果可用)。

设置会返回更新后的文档,如果该文档不可用,则会引发错误。有关此变更流选项如何工作的更多信息,请参阅MongoDB手册中的查找更新操作的完整文档。默认值:

updateLookup

whenAvailable

required



""
接受值:"""updateLookup""whenAvailable""required"

更改。 流.show.expanded.events

类型:布尔值 描述:确定变更流是否通知


DDL 事件,例如
createIndexes
dropIndexes
事件。要学习;了解更多信息,请参阅 showExpandedEvents。此设置需要在更新事件中显示


updateDescription.disambiguatedPaths
,这会澄清涉及不明确字段的更改。要学习;了解更多信息,请参阅
disambiguatedPaths。默认值:

false
接受值:truefalse

change.stream.full.document.before.change

类型:字符串






描述:配置变更流在更新操作中返回的文档前像。前像对于复制现有数据时发布的源记录不可用,并且前像配置对复制没有影响。要学习;了解如何配置集合以启用前像,请参阅MongoDB手册中的具有文档前像和后像的变更流。默认设置会抑制文档前像。

whenAvailable设置会返回替换、更新或删除之前的文档前像(如果可用)。

required设置返回文档前像,如果不可用,则引发错误。默认值:

""
接受值:"""whenAvailable""required"

publish.full.document.only

类型:布尔值 描述:是否仅返回任何更新事件生成的变更流事件文档中的


fullDocument字段。fullDocument 字段包含最新版本的更新文档。要学习;了解有关 字段的更多信息,请参阅服务器手册中的更新事件。当设立为fullDocument

true时,Connector会覆盖change.stream.full.document 设置并将其设置为 ,以便updateLookup fullDocument

false
字段包含更新的文档。默认值: 接受值:truefalse

publish.full.document.only.tombstone.on.delete

类型:布尔值


描述:删除文档时是否返回逻辑删除事件。逻辑删除事件包含具有null 值的已删除文档的密钥。此设置仅当 为 时适用。默认值:publish.full.document.only true

false
接受值:truefalse

change.stream.document.key.as.key

类型:布尔值


描述:如果文档键存在,是否使用文档键作为源记录键。当设立为

true时,Connector会将已删除文档的密钥添加到 tombstone 事件中。当设立为false 时,Connector使用恢复令牌作为 tombstone 事件的源密钥。默认值:

true
接受值:truefalse

排序规则

类型:字符串


描述:一份JSON排序规则文档,用于指定MongoDB应用于变更流返回的文档的特定于语言的排序规则。默认值:

""
接受值:有效的排序规则JSON 文档

batch.size

类型:int


描述:变更流游标批处理大小。默认值:

0
接受值:整数

poll.await.time.ms

类型:long


描述:服务器在返回空批处理之前等待新数据更改报告给变更流游标的最长时间(以毫秒为单位)。默认值:

5000
接受值:整数

poll.max.batch.size

类型:int


描述:轮询变更流游标以获取新数据时,单个批处理中读取的最大文档数。您可以使用此设置来限制Connector内部缓冲的数据量。默认值:

1000
接受值:整数

在此页面上