HoistField¶
ここでは、Apache Kafka® SMT org.apache.kafka.connect.transforms.HoistField
の使用方法を説明します。
説明¶
データにスキーマがある場合は、Struct で指定されたフィールド名を使用してデータがラップされます。データにスキーマがない場合は、Map で指定されたフィールド名を使用してデータがラップされます。
レコードキー用(org.apache.kafka.connect.transforms.HoistField$Key
)または値用(org.apache.kafka.connect.transforms.HoistField$Value
)の固有の変換タイプを使用します。
例¶
次の構成スニペットは、HoistField
を使用して Struct のフィールド名をラップする方法を示しています。
"transforms": "HoistField",
"transforms.HoistField.type": "org.apache.kafka.connect.transforms.HoistField$Value",
"transforms.HoistField.field": "line"
送信メッセージ:
Foo
Bar
トピックの結果:
{"line":"Foo"}
{"line":"Bar"}
ちなみに
その他の例については、マネージド型コネクターの Hoist Field を参照してください。
特徴¶
Name | 説明 | 型 | デフォルト | 指定可能な値 | 重要度 |
---|---|---|---|---|---|
field |
変換後の Struct または Map に作成される単一のフィールドのフィールド名。 | string | 空でないリスト | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。