重要
このページの日本語コンテンツは古くなっている可能性があります。最新の英語版コンテンツをご覧になるには、こちらをクリックしてください。
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 によって値がどのデータ型に解析されるかをまとめています。
プロパティ¶
| 名前 | 説明 | 型 | デフォルト | 指定可能な値 | 重要度 |
|---|---|---|---|---|---|
header |
変換で使用するヘッダー名。 | string | null でない文字列 | 中 | |
value |
各レコードに追加するヘッダー値。値がプリミティブリテラル（32 ビット整数、ブール値、null など）または複素数リテラル（JSON に似た構文で示される配列やマップなど）と考えられる場合、値は解析され、解析された型でヘッダーに追加されます。それ以外の場合、このプロパティの raw 文字列は、そのまま使用されます。 | string | null でない文字列 | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter（Apache Kafka） と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。