| 类型:list
说明: 连接器应在将数据保存到 MongoDB 之前应用的后处理器类列表。
要进一步了解后处理器并查看其用法示例,请参阅 Sink Connector 后处理器 。
默认: | com.mongodb.kafka.connect.sink.processor.DocumentIdAdder |
接受的值:以逗号分隔的完全限定 Java 类名称列表 |
| 类型:string
说明: 键和值字段的字段名称映射列表。以以下格式在内联 JSON 数组中定义映射: | [ { "oldName":"key.fieldA", "newName":"field1" }, { "oldName":"value.xyz", "newName":"abc" } ] |
默认:[] 接受值:有效的 JSON 数组 |
| 类型:string
说明: 使用正则表达式对关键字段和值字段进行字段名称映射的列表。以以下格式在内联 JSON 数组中定义映射: | [ {"regexp":"^key\\\\..*my.*$", "pattern":"my", "replace":""}, {"regexp":"^value\\\\..*$", "pattern":"\\\\.", "replace":"_"} ] |
默认:[] 接受值:有效的 JSON 数组 |
| 类型:string
说明: 连接器应包含在关键投影中的字段名称列表。
默认:"" 可接受值:字段名称的逗号分隔列表 |
| 类型:string
说明: 连接器应使用的密钥投影类型。
默认 : 可接受值none :none 、BlockList 或AllowList (已弃用:黑名单、白名单) |
| 类型:string
说明: 连接器应包含在值投影中的字段名称列表。
默认:"" 可接受值:字段名称的逗号分隔列表 |
| 类型:string
说明: 连接器应使用的值投影类型。
默认 : 可接受值none :none 、BlockList 或AllowList (已弃用:黑名单、白名单) |
| 类型: string
说明: 指定连接器应用于 批量写入的 WriteModelStrategy的类。
要了解如何创建自己的策略,请参阅 自定义写入模型策略。
默认: | com.mongodb.kafka.connect.sink.writemodel.strategy.DefaultWriteModelStrategy |
接受值:完全限定的 Java 类名称 |