InsertHeader¶
ここでは、Apache Kafka® SMT org.apache.kafka.connect.transforms.InsertHeader
の使用方法を説明します。
注意
InsertHeader は現在、マネージド型コネクター では利用できません。
説明¶
各レコードのヘッダーを挿入します。
サンプル¶
この構成スニペットは、InsertHeader
を使用して、リテラル値 best-app-ever
を持つ app.id
という名前のヘッダーを各レコードに挿入する方法を示しています。
"transforms": "insertAppIdHeader",
"transforms.insertAppIdHeader.type": "org.apache.kafka.connect.transforms.InsertHeader",
"transforms.insertAppIdHeader.header": "app.id",
"transforms.insertAppIdHeader.value.literal": "best-app-ever"
変換前: app.id
という名前のヘッダーまたは値はレコードに存在しません。
変換後: 各レコードにヘッダー値 best-app-ever
が含まれます。
上記の例では、Connect によってリテラル値 best-app-ever
が STRING 型 に解析されます。以下に、value プロパティのサンプル値と Connect によって値がどのデータ型に解析されるかを示します。
特徴¶
Name | 説明 | 型 | デフォルト | 指定可能な値 | 重要度 |
---|---|---|---|---|---|
header |
変換で使用するヘッダー名。 | string | null でない文字列 | 中 | |
value |
各レコードに追加するヘッダー値。値がプリミティブリテラル(32 ビット整数、ブール値、null など)または複素数リテラル(JSON に似た構文で示される配列やマップなど)と考えられる場合、値は解析され、解析された型としてヘッダーに追加されます。それ以外の場合、このプロパティの raw 文字列は、そのまま使用されます。 | string | null でない文字列 | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。