对于 AI 代理：可在 https://www.mongodb.com/zh-cn/docs/llms.txt 获取文档索引—通过在任何 URL 路径后添加 .md 可获取所有页面的 Markdown 版本。
Docs 菜单
Docs 主页
/ /
配置属性
Docs 主页
/ /
接收器连接器
/
配置属性
Docs 主页
/
工具
/
Kafka Connector
/
接收器连接器
/
配置属性

接收连接器写入模型策略

Overview

您可以设置配置属性来指定MongoDB Kafka Sink connector如何将数据写入MongoDB 。 以下部分介绍了可以设置的配置属性，可自定义此行为。

WriteModel

将 writemodel.strategy 配置属性设置为 ，以指定接收器connector在接收接收器记录时如何写入数据。

您可以设立writemodel.strategy的值设置为本页“策略”部分中描述的写入模型策略的任何完全限定类名称。 您可以通过设置以下配置来指定策略：

writemodel.strategy=<a write model strategy>

删除写入模型

将 delete.writemodel.strategy 配置属性设置为 ，以指定 Sink connector在收到 tombstone 事件时如何写入数据。 逻辑删除事件是指包含键但不包含值的记录，这表示记录已删除。

您可以设立delete.writemodel.strategy的值设置为本页“策略”部分中描述的写入模型策略的任何完全限定类名称。 您可以通过设置以下配置来指定策略：

delete.writemodel.strategy=<a write model strategy>

有关按类别组织的接收器连接Connector配置设置列表，请参阅接收器连接器配置属性指南。

Strategies

名称
说明

DefaultWriteModelStrategy

描述：
此策略默认使用 ReplaceOneDefaultStrategy，如果设置 timeseries.timefield 选项，则使用 InsertOneDefaultStrategy。

这是 writemodel.strategy 配置属性的默认值。

InsertOneDefaultStrategy

描述：
将每个 sink 记录作为文档插入 MongoDB。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy

ReplaceOneDefaultStrategy

描述：
根据 _id 字段，替换 MongoDB 中至多一个匹配接收记录的文档。如果没有任何文档匹配，连接器会将接收记录作为新文档插入。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

替换一个业务键策略

描述：
按指定的业务密钥替换与汇总记录匹配的最多一个文档。如果没有文档匹配，连接器会将汇总记录作为新文档插入。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy

要查看如何使用此策略的示例，请参阅我们的 写模型策略 指南。

DeleteOneDefaultStrategy

描述：
最多删除一个与您的汇总连接器的关键结构匹配的文档，按 _id 字段，仅当文档包含空值结构时。

这是配置属性 delete.writemodel.strategy 的默认值。

当您设置 delete.on.null.values=true 时，此策略将设置为 writemodel.strategy 属性的默认值。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy

删除一个业务键策略

描述：
最多删除一个与业务密钥匹配的汇总记录的 MongoDB 文档。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy

要查看如何使用此策略的示例，请参阅我们的 写模型策略 指南。

UpdateOneDefaultStrategy

描述：
最多更新 MongoDB 中一个与汇总记录匹配的文档，按 _id 字段。如果没有文档匹配，连接器会将汇总记录作为新文档插入。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy

更新一个时间戳策略

描述：
在文档中添加 _insertedTS (插入时间戳) 和 _modifiedTS (修改时间戳) 字段。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy

要查看如何使用此策略的示例，请参阅我们的 写模型策略 指南。

UpdateOneBusinessKeyTimestampStrategy

描述：
在符合业务键的文档中添加 _insertedTS（插入时间戳）和 _modifiedTS（修改时间戳）字段。
要指定此策略，请将配置属性设置为以下类名：

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

后退

Id 策略

来年

主题覆盖

在此页面上