Apply the XJ Template Transformation to transform JSON to XML and XML to JSON.
Updated 2026-10-12 05:29:07 +00:00
Apply the XJ Identity Transformation to transform JSON to XML and XML to JSON.
Updated 2026-10-12 05:29:07 +00:00
Replace the Kafka record key with a new key formed from a fields subset coming from the message body.
Updated 2026-10-12 05:29:05 +00:00
Apply a Velocity Template.
Updated 2026-10-12 05:29:05 +00:00
Update the topic field as a function of the original topic name and the record timestamp.
Updated 2026-10-12 05:29:03 +00:00
Filter based on kafka topic value compared to regex.
Updated 2026-10-12 05:29:03 +00:00
The Throttle action allows you to ensure that a specific sink does not get overloaded.
Updated 2026-10-12 05:29:02 +00:00
Apply a String Template.
Updated 2026-10-12 05:29:01 +00:00
Filter based on simple expression.
Updated 2026-10-12 05:28:55 +00:00
Set Kafka Key based on a specific incoming header value from the message body.
Updated 2026-10-12 05:28:54 +00:00
Sets a simple language parsed value as the new message body in transit.
Updated 2026-10-12 05:28:53 +00:00
Replace field with a different key in the message in transit.
Updated 2026-10-12 05:28:50 +00:00
Resolves schema from given mime type and payload. Sets the resolved schema, the schema type and its content class as properties for later reference.
Updated 2026-10-12 05:28:50 +00:00
Update the destination using the configured regular expression and replacement string.
Updated 2026-10-12 05:28:49 +00:00
Deserialize payload to Protobuf.
Updated 2026-10-12 05:28:47 +00:00
Serialize payload to Protobuf.
Updated 2026-10-12 05:28:47 +00:00
Filter based on a JSONPath Expression. Since this is a filter, the expression is a negation. This means that if the `foo` field of the example is equal to `John`, the message goes ahead. Otherwise it is filtered out.
Updated 2026-10-12 05:28:47 +00:00
Apply a Mvel Template.
Updated 2026-10-12 05:28:40 +00:00
Apply a Mustache Template.
Updated 2026-10-12 05:28:40 +00:00
Update the topic field as a function of the original topic name and the record's timestamp field.
Updated 2026-10-12 05:28:36 +00:00