Sink Connector ポストプロセッサのプロパティ

post.processor.link

タイプ: 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.regex

タイプ: string

説明:
正規表現を使用した、キー フィールドと値フィールドのフィールド名マッピングのリスト。次の形式のインラインJSON配列でマッピングを定義します。

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

デフォルト:[]
許容値: 有効なJSON配列

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.stratey

タイプ: string 説明:コネクタが一括書き込みに使用する


WriteModelStrategyを指定するクラス。独自の戦略を作成する方法の詳細については、「

カスタム書込みモデル戦略 」を参照してください。デフォルト:

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

許容値: 完全修飾 Java クラス名