对于 AI 代理:可在 https://www.mongodb.com/zh-cn/docs/llms.txt 获取文档索引—通过在任何 URL 路径后添加 .md 可获取所有页面的 Markdown 版本。
Docs 菜单

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

使用以下配置设置指定 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
noneBlockListAllowList (已弃用:黑名单、白名单)

value.projection.list

类型:string

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

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

value.projection.type

类型:string

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

默认 : 可接受值none
noneBlockListAllowList (已弃用:黑名单、白名单)

writemodel.strategy

类型: string

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

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

默认:

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

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

在此页面上