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
Filter based on kafka topic value compared to regex.
Updated 2026-10-12 05:29:03 +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
Set Kafka Key based on a specific incoming header value from the message body.
Updated 2026-10-12 05:28:54 +00:00
Update the destination using the configured regular expression and replacement string.
Updated 2026-10-12 05:28:49 +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
Send data to Kafka topics.
Updated 2026-10-12 05:28:31 +00:00
Receive data from Kafka topics.
Updated 2026-10-12 05:28:31 +00:00
Receive data from Kafka topics on an insecure broker combined with Apicurio Registry secured with Keycloak.
Updated 2026-10-12 05:28:31 +00:00
Receive data from Kafka topics on an insecure broker combined with Apicurio Registry secured with Keycloak for JSON Schema support.
Updated 2026-10-12 05:28:30 +00:00
Send data to Kafka topics on an insecure broker with Apicurio Registry secured with Keycloak.
Updated 2026-10-12 05:28:30 +00:00
Manually commit Kafka Offset.
Updated 2026-10-12 05:28:29 +00:00
Manually commit Kafka Batch Offset.
Updated 2026-10-12 05:28:29 +00:00
Receive data from Kafka topics in batch and commit them manually through KafkaManualCommit. This provides complete control over when messages are committed, allowing for custom processing logic before acknowledgment.
Updated 2026-10-12 05:28:29 +00:00
Receive data from Kafka topics in batch on Azure Eventhubs combined with Azure Schema Registry and commit them manually through KafkaManualCommit or auto commit.
Updated 2026-10-12 05:28:28 +00:00
Receive data from Kafka topics in batch on an insecure broker combined with Apicurio Registry secured with Keycloak and commit them manually through KafkaManualCommit or auto commit.
Updated 2026-10-12 05:28:28 +00:00
Receive data from Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
Updated 2026-10-12 05:28:27 +00:00
Send data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
Updated 2026-10-12 05:28:27 +00:00
Receive data from Kafka topics in batch on an insecure broker combined with Apicurio Registry and commit them manually through KafkaManualCommit or auto commit.
Updated 2026-10-12 05:28:27 +00:00
Send data to Kafka topics on an insecure broker with Apicurio Registry.
Updated 2026-10-12 05:28:26 +00:00