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