对于 AI 代理:可在 https://www.mongodb.com/zh-cn/docs/llms.txt 获取文档索引—通过在任何 URL 路径后添加 .md 可获取所有页面的 Markdown 版本。
Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Docs 菜单

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

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

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

名称
说明

post.processor.chain

类型:列表


描述:Connector在将数据保存到MongoDB之前应应用以进程数据的后处理器类的列表。要学习;了解有关后处理器的更多信息并查看其用法示例,请参阅



Sink Connector 后处理器。默认值:

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

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

field.renamer.mapping

类型:字符串


描述:键字段和值字段的字段名称映射列表。按以下格式在内联JSON大量中定义映射:

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

默认值:[]
接受的值:有效的JSON大量

field.renamer.regexp

类型:字符串


描述:使用正则表达式的键和值字段的字段名称映射列表。按以下格式在内联JSON大量中定义映射:

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

默认值:[]
接受的值:有效的JSON大量

key.projection.list

类型:字符串


描述:Connector应包含在键投影中的字段名称列表。默认值:

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

key.projection.type

类型:字符串


描述:Connector应使用的键投影类型。默认值:

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

value.projection.list

类型:字符串


描述:Connector应包含在值投影中的字段名称列表。默认值:

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

value.projection.type

类型:字符串


描述:Connector应使用的值投影类型。默认值:

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

writemodel.strategy

类型:字符串 描述:该类指定Connector应用于批量写入的


WriteModelStrategy。要学习;了解有关如何创建自己的策略的更多信息,请参阅自定义写入模型策略。默认值:




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

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

在此页面上