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

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 数组

field.value.transformer

类型：string

说明：
FieldValueTransformer 实现的完全限定类名。配置后，连接器会将指定的转换器应用于 field.value.transformer.fields 中列出的字段，然后写入 MongoDB。该类必须实现 com.mongodb.kafka.connect.sink.processor.field.transform.FieldValueTransformer 并具有公共无参构造函数。

默认值：""
接受值：完全限定的 Java 类名

字段.value.transformer.字段s

类型： string

说明：
逗号分隔的字段名称列表，连接器将配置的 FieldValueTransformer 应用于该列表。连接器还会转换子文档中名称匹配的嵌套字段。

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

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

类型： string

说明：
指定连接器应用于 批量写入的 WriteModelStrategy的类。

要了解如何创建自己的策略，请参阅
自定义写入模型策略。

默认:

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

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