重要
このページの日本語コンテンツは古くなっている可能性があります。最新の英語版コンテンツをご覧になるには、こちらをクリックしてください。
DropHeaders¶
ここでは、Apache Kafka® SMT org.apache.kafka.connect.transforms.DropHeaders
の使用方法を説明します。
注意
DropHeaders は現在、マネージド型コネクター では利用できません。
説明¶
各レコードから 1 つまたは複数のヘッダーをドロップします。
サンプル¶
この構成スニペットは、DropHeaders
を使用して、app.id
および txn.id
という名前のヘッダーをドロップする方法を示しています。
"transforms": "dropAppIdHeader",
"transforms.dropAppIdHeader.type": "org.apache.kafka.connect.transforms.DropHeaders",
"transforms.dropAppIdHeader.headers": "app.id,txn.id"
変換前: ヘッダー app.id
と txn.id
はレコードに含まれています。
変換後: ヘッダー app.id
と txn.id
がレコードからドロップされます。
プロパティ¶
名前 | 説明 | 型 | 指定可能な値 | 重要度 | |
---|---|---|---|---|---|
headers |
ドロップする 1 つまたは複数の(コンマ区切りの)ヘッダー名。 | string | 空でないリスト | 中 |
述語¶
"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。