Replace the Kafka record key with a new key formed from a fields subset coming from the message body
Updated 2026-03-11 14:31:24 +00:00
The Throttle action allows you to ensure that a specific sink does not get overloaded.
Updated 2026-03-11 14:31:20 +00:00
Filter based on kafka topic value compared to regex
Updated 2026-03-11 14:31:20 +00:00
Update the topic field as a function of the original topic name and the record timestamp.
Updated 2026-03-11 14:31:20 +00:00
Filter based on simple expression
Updated 2026-03-11 14:31:17 +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-03-11 14:31:15 +00:00
Update the destination using the configured regular expression and replacement string
Updated 2026-03-11 14:31:14 +00:00
Deserialize payload to Protobuf
Updated 2026-03-11 14:31:14 +00:00
Serialize payload to Protobuf
Updated 2026-03-11 14:31:14 +00:00
Filter based on a JsonPath Expression. Since this is a filter, the expression will be a negation, this means that if the foo field of the example is equals to John, the message will go ahead, otherwise it will be filtered out.
Updated 2026-03-11 14:31:13 +00:00