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 (非推奨: blacklist、whitelist)

value.projection.list

〈strong〉タイプ：〈/strong〉 string〈br


/〉〈br /〉〈strong〉説明：〈/strong〉〈br /〉コネクターが値プロジェクションに含める必要があるフィールド名のリスト。〈br /〉〈br /〉

デフォルト: ""
受け入れられる値: フィールド名のカンマ区切りリスト

value.projection.type

タイプ: string

説明:
コネクターが使用する値プロジェクションのタイプ。

デフォルト:none
受け入れ可能な値:none 、BlockList 、またはAllowList (非推奨: blacklist、whitelist)

writemodel.stratey

Type: string

Description:
The class that specifies the WriteModelStrategy the connector should use for Bulk Writes.

To learn more about how to create your own strategy, see
Custom Write Model Strategies.

Default:

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

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