camel-apache-org/value-to-key-action
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
camel-apache-org/topic-name-matches-filter-action
Filter based on kafka topic value compared to regex.
Updated 2026-10-12 05:29:03 +00:00
camel-apache-org/timestamp-router-action
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
camel-apache-org/set-kafka-key-action
Set Kafka Key based on a specific incoming header value from the message body.
Updated 2026-10-12 05:28:54 +00:00
camel-apache-org/regex-router-action
Update the destination using the configured regular expression and replacement string.
Updated 2026-10-12 05:28:49 +00:00
camel-apache-org/message-timestamp-router-action
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
camel-apache-org/kafka-sink
Send data to Kafka topics.
Updated 2026-10-12 05:28:31 +00:00
camel-apache-org/kafka-source
Receive data from Kafka topics.
Updated 2026-10-12 05:28:31 +00:00
camel-apache-org/kafka-not-secured-apicurio-registry-source
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
camel-apache-org/kafka-not-secured-apicurio-registry-json-source
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
camel-apache-org/kafka-not-secured-apicurio-registry-sink
Send data to Kafka topics on an insecure broker with Apicurio Registry secured with Keycloak.
Updated 2026-10-12 05:28:30 +00:00
camel-apache-org/kafka-manual-commit-action
Manually commit Kafka Offset.
Updated 2026-10-12 05:28:29 +00:00
camel-apache-org/kafka-batch-manual-commit-action
Manually commit Kafka Batch Offset.
Updated 2026-10-12 05:28:29 +00:00
camel-apache-org/kafka-batch-source
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
camel-apache-org/kafka-batch-azure-schema-registry-source
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
camel-apache-org/kafka-batch-apicurio-registry-source
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
camel-apache-org/kafka-azure-schema-registry-source
Receive data from Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
Updated 2026-10-12 05:28:27 +00:00
camel-apache-org/kafka-azure-schema-registry-sink
Send data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
Updated 2026-10-12 05:28:27 +00:00
camel-apache-org/kafka-batch-apicurio-registry-not-secured-source
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
camel-apache-org/kafka-apicurio-registry-not-secured-sink
Send data to Kafka topics on an insecure broker with Apicurio Registry.
Updated 2026-10-12 05:28:26 +00:00