Kafka Connect InsertField SMT Usage Reference for Confluent Cloud or Confluent Platform¶
The following provides usage information for the Apache Kafka® SMT org.apache.kafka.connect.transforms.InsertField.
Description¶
Insert fields using attributes from the record metadata or a configured static value.
Use the concrete transformation type designed for the record key (org.apache.kafka.connect.transforms.InsertField$Key) or value (org.apache.kafka.connect.transforms.InsertField$Value).
Example¶
This configuration snippet shows how to use InsertField to insert a static
field labeled MessageSource using a static value of 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"
Before: {"author": "Philip K. Dick", "character": "Palmer Eldritch"}
After: {"author": "Philip K. Dick", "character": "Palmer Eldritch", "MessageSource": "Kafka Connect framework"}
Tip
For additional examples, see Insert Field for managed connectors.
Properties¶
| Name | Description | Type | Default | Valid Values | Importance |
|---|---|---|---|---|---|
offset.field |
Field name for Apache Kafka® offset. This is only applicable to sink connectors. Suffix with ! to make this a required field, or ? to keep it optional (the default). |
string | null | medium | |
partition.field |
Field name for Kafka partition. Suffix with ! to make this a required field, or ? to keep it optional (the default). |
string | null | medium | |
static.field |
Field name for static data field. Suffix with ! to make this a required field, or ? to keep it optional (the default). |
string | null | medium | |
static.value |
If field name is configured, the static field value. | string | null | medium | |
timestamp.field |
Field name for record timestamp. Suffix with ! to make this a required field, or ? to keep it optional (the default). |
string | null | medium | |
topic.field |
Field name for Kafka topic. Suffix with ! to make this a required field, or ? to keep it optional (the default). |
string | null | medium |
Predicates¶
Transformations can be configured with predicates so that the transformation is applied only to records which satisfy a condition. You can use predicates in a transformation chain and, when combined with the Kafka Connect Filter (Kafka) SMT Usage Reference for Confluent Cloud or Confluent Platform, predicates can conditionally filter out specific records. For details and examples, see Predicates.