InsertField

ここでは、Apache Kafka® SMT org.apache.kafka.connect.transforms.InsertField の使用方法を説明します。

説明

レコードメタデータの属性または構成可能な静的な値を使用してフィールドを挿入します。

レコードキー用(org.apache.kafka.connect.transforms.InsertField$Key)または値用(org.apache.kafka.connect.transforms.InsertField$Value)の固有の変換タイプを使用します。

この構成スニペットは、InsertField を使用して、静的フィールドを 1 つ挿入する方法を示しています。フィールドには MessageSource というラベルを付加し、静的な値の Kafka Connect Framework を使用します。

"transforms": "InsertField",
"transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Value",
"transforms.InsertField.static.field": "MessageSource",
"transforms.InsertField.static.value": "Kafka Connect framework"

変換前 : {"author": "Philip K. Dick", "character": "Palmer Eldritch"}

変換後: {"author": "Philip K. Dick", "character": "Palmer Eldritch", "MessageSource": "Kafka Connect framework"}

ちなみに

その他の例については、マネージド型コネクターの Insert Field を参照してください。

特徴

Name 説明 デフォルト 指定可能な値 重要度
offset.field Apache Kafka® オフセットのフィールド名。これは、シンクコネクターのみに適用されます。サフィックス ! を使用すると必須フィールドに、? を使用すると省略可能になります(デフォルト)。 string null  
partition.field Kafka パーティションのフィールド名。サフィックス ! を使用すると必須フィールドに、? を使用すると省略可能になります(デフォルト)。 string null  
static.field 静的なデータフィールドのフィールド名。サフィックス ! を使用すると必須フィールドに、? を使用すると省略可能になります(デフォルト)。 string null  
static.value フィールド名が構成されている場合は、静的なフィールド値。 string null  
timestamp.field レコードのタイムスタンプのフィールド名。サフィックス ! を使用すると必須フィールドに、? を使用すると省略可能になります(デフォルト)。 string null  
topic.field Kafka トピックのフィールド名。サフィックス ! を使用すると必須フィールドに、? を使用すると省略可能になります(デフォルト)。 string null  

述語

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