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) と組み合わせると、条件に基づいて特定のレコードを除外できます。詳細と例については、「述語」を参照してください。