接收连接器写入模型策略

Overview

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

WriteModel

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

You can set the value of writemodel.strategy to any of the fully qualified class names of the write model strategies described in the Strategies section of this page. You can specify a strategy by setting the following configuration:

writemodel.strategy=<a write model strategy>

删除写入模型

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

You can set the value of delete.writemodel.strategy to any of the fully qualified class names of the write model strategies described in the Strategies section of this page. You can specify a strategy by setting the following configuration:

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 文档。此策略需要 valueDoc 来生成密钥。要利用 PartialKeyStrategy 生成密钥，请使用 DeleteOneTombstoneBusinessKeyStrategy。

要指定此策略，请将配置属性设置为以下类名：

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

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

删除单个墓碑业务键策略

描述：
最多删除一个与业务密钥的汇流记录匹配的 MongoDB 文档。此策略利用 PartialKeyStrategy 创建用于删除的密钥。

要指定此策略，请将配置属性设置为以下类名：

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

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