/ /

/ /

接收连接器写入模型策略

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 InsertOneDefaultStrategytimeseries.timefield，如果设立了选项，则使用。这是

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

InsertOneDefaultStrategy

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

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

ReplaceOneDefaultStrategy

描述：
在MongoDB中最多替换一个由_id 字段匹配 Sink记录的文档。如果没有匹配的文档，Connector会将
Sink记录作为新文档插入。要指定此策略，设立属性设置为以下类名：

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

替换一个业务键策略

描述：
最多替换一个与指定业务键 Sink记录匹配的文档。如果没有匹配的文档，Connector会将 Sink记录作为新文档插入。要指定此策略，设立属性设置为以下类名：

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

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

DeleteOneDefaultStrategy

描述：仅当文档包含 null 值结构时，才最多删除一个通过
字段与接收器连接器的键结构匹配的文档。这是配置属性的默认值。当您设立_id

delete.writemodel.strategy

时，此策略将被设立为属性的默认值。要指定此策略，设立属性设置为以下类名：writemodel.strategydelete.on.null.values=true

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

删除一个业务键策略

描述：
最多删除一个通过业务键与 Sink记录匹配的MongoDB文档。此策略需要使用valueDoc 来生成密钥。要利用PartialKeyStrategy 生成密钥，请使用。要指定此策略，设立属性设置为以下类名：DeleteOneTombstoneBusinessKeyStrategy

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

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

DeleteOneTombstone BusinessKeyStrategy

描述：
最多删除一个通过业务键与 Sink记录匹配的MongoDB文档。此策略利用创建用于删除的密钥。要指定此策略，设立属性设置为以下类名：PartialKeyStrategy

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

UpdateOneDefaultStrategy

描述：
在MongoDB中最多更新一个通过_id 字段匹配 Sink记录的文档。如果没有匹配的文档，Connector会将
Sink记录作为新文档插入。要指定此策略，设立属性设置为以下类名：

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 策略

来年

主题覆盖