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.idtxn.id はレコードに含まれています。

変換後: ヘッダー app.idtxn.id がレコードからドロップされます。

特徴

Name 説明 種類   指定可能な値 重要度
headers ドロップする 1 つ以上の(コンマ区切りの)ヘッダー名。 string   空でないリスト

述語

"述語" を使用することにより、一定の条件を満たすレコードのみに変換が適用されるように、変換を構成することができます。述語は変換チェーンで使用することができ、Filter(Apache Kafka) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。