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) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。