接收器连接器后处理器属性

Overview

使用以下配置设置指定 MongoDB Kafka connector 在将 Kafka 数据插入 MongoDB 之前应如何转换该数据。

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

设置

名称

说明

post.processor.chain

类型：list

说明：
连接器应在将数据保存到 MongoDB 之前应用的后处理器类列表。

要进一步了解后处理器并查看其用法示例，请参阅

Sink Connector 后处理器。

默认:

com.mongodb.kafka.connect.sink.processor.DocumentIdAdder

接受的值：以逗号分隔的完全限定 Java 类名称列表

field.renamer.mapping

类型：string

说明：
键和值字段的字段名称映射列表。以以下格式在内联 JSON 数组中定义映射：

[ { "oldName":"key.fieldA", "newName":"field1" }, { "oldName":"value.xyz", "newName":"abc" } ]

默认：[]
接受值：有效的 JSON 数组

field.renamer.regexp

类型：string

说明：
使用正则表达式对关键字段和值字段进行字段名称映射的列表。以以下格式在内联 JSON 数组中定义映射：

[ {"regexp":"^key\\\\..*my.*$", "pattern":"my", "replace":""}, {"regexp":"^value\\\\..*$", "pattern":"\\\\.", "replace":"_"} ]

默认：[]
接受值：有效的 JSON 数组

key.projection.list

类型：string

说明：
连接器应包含在关键投影中的字段名称列表。

默认：""
可接受值：字段名称的逗号分隔列表

key.projection.type

类型：string

说明：
连接器应使用的密钥投影类型。

默认：可接受值none
：none 、BlockList 或AllowList (已弃用：黑名单、白名单)

value.projection.list

类型：string

说明：
连接器应包含在值投影中的字段名称列表。

默认：""
可接受值：字段名称的逗号分隔列表

value.projection.type

类型：string

说明：
连接器应使用的值投影类型。

默认：可接受值none
：none 、BlockList 或AllowList (已弃用：黑名单、白名单)

writemodel.strategy

Type: string

Description:
The class that specifies the WriteModelStrategy the connector should use for Bulk Writes.

To learn more about how to create your own strategy, see
Custom Write Model Strategies.

Default:

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

接受值：完全限定的 Java 类名称