Kamelet Catalog

This version (Next (Pre-release)) of Kamelet Catalog depends on:

Camel at version 4.8.0

It is not currently used by other subprojects such as camel-k or camel-kafka-connector.

This is the development version of Kamelet Catalog. It should not be used in production.

Kamelet specification

Kamelets were originally born for Kubernetes and they have eventually moved to be used as Camel core resources. Its specification is a Kubernetes CRD specification. You can use it in your project by using Maven dependency org.apache.camel.kamelets:camel-kamelets-crds.

Development guide

Kamelets are extensible components. Look at the guide and learn how to develop a new Kamelet.

Compatibility Matrix

Compatibility between Kamelets catalog and related subprojects
Camel-Kamelets Version	Using Camel Version	Used by Camel-K Version	Used by Camel-Kafka-Connector Version	LTS Until	Branch
Next (Pre-release)	4.8.0				main
4.8.x (LTS)	4.8.2				4.8.x
4.4.x (LTS)	4.4.3				4.4.x

This page contains the default Apache Camel Kamelets catalog.

Consult the Kamelets User Guide for information about how to use these.

We love contributions for this catalog: you can follow the Kamelets Developer Guide for information on how to create new Kamelets and contribute them to the official github.com/apache/camel-kamelets repository.

avro deserialize action Avro Deserialize Action

avro serialize action Avro Serialize Action

aws bedrock agent runtime sink AWS Bedrock Agent Runtime Sink

aws bedrock text sink AWS Bedrock Text Sink

aws cloudtrail source AWS Cloudtrail Source

aws cloudwatch sink AWS CloudWatch Metrics Sink

aws ddb sink AWS DynamoDB Sink

aws ddb streams source AWS DynamoDB Streams Source

aws ec2 sink AWS EC2 Sink

aws eventbridge sink AWS Eventbridge Sink

aws kinesis firehose sink AWS Kinesis Firehose Sink

aws kinesis sink AWS Kinesis Sink

aws kinesis source AWS Kinesis Source

aws lambda sink AWS Lambda Sink

aws redshift sink AWS Redshift Sink

aws redshift source AWS Redshift Source

aws s3 event based source AWS S3 Event Based Source

aws s3 sink AWS S3 Sink

aws s3 source AWS S3 Source

aws s3 streaming upload sink AWS S3 Streaming upload Sink

aws secrets manager sink AWS Secrets Manager Sink

aws ses sink AWS SES Sink

aws sns fifo sink AWS SNS FIFO Sink

aws sns sink AWS SNS Sink

aws sqs batch sink AWS SQS Batch Sink

aws sqs fifo sink AWS SQS FIFO Sink

aws sqs sink AWS SQS Sink

aws sqs source AWS SQS Source

aws sts assume role action AWS STS Assume Role Action

aws timestream query sink AWS Timestream Query Sink

aws translate action AWS Translate Action

azure cosmosdb sink Azure CosmosDB Sink

azure cosmosdb source Azure CosmosDB Source

azure eventhubs sink Azure Eventhubs Sink

azure eventhubs source Azure Eventhubs Source

azure functions sink Azure Function Sink

azure servicebus sink Azure Servicebus Sink

azure servicebus source Azure Servicebus Source

azure storage blob append sink Azure Storage Blob Append Sink

azure storage blob changefeed source Azure Storage Blob Changefeed Source

azure storage blob event based source Azure Storage Blob Event-based Source

azure storage blob sink Azure Storage Blob Sink

azure storage blob source Azure Storage Blob Source

azure storage datalake sink Azure Storage Blob Data Lake Sink

azure storage datalake source Azure Storage Blob Data Lake Source

azure storage files sink Azure Storage Files Sink

azure storage files source Azure Storage File Source

azure storage queue sink Azure Storage Queue Sink

azure storage queue source Azure Storage Queue Source

beer source Beer Source

bitcoin source Bitcoin Source

caffeine action Caffeine Action

cassandra sink Cassandra Sink

cassandra source Cassandra Source

ceph sink Ceph Sink

ceph source Ceph Source

chuck norris source Chuck Norris Source

chunk template action Chunk Template Action

coffee source Coffee Source

couchbase sink Couchbase Sink

counter source Counter Source

cron source Cron Source

data type action Data Type Action

delay action Delay Action

djl image to text action Image-to-Text Action

dns dig action DNS DIG Action

dns ip action DNS IP Action

dns lookup action DNS Lookup Action

drop field action Drop Field Action

drop header action Drop Header Action

drop headers action Drop Headers Action

dropbox sink Dropbox Sink

dropbox source Dropbox Source

earthquake source Earthquake Source

elasticsearch index sink ElasticSearch Index Sink

ElasticSearch Search Source

exec sink Exec Sink

extract field action Extract Field Action

fhir sink FHIR Sink

fhir source Fhir Source

file watch source File Watch Source

freemarker template action Freemarker Template Action

ftp sink FTP Sink

ftp source FTP Source

ftps sink FTPS Sink

ftps source FTPS Source

github commit source GitHub Commit Source

github event source GitHub Event Source

github pullrequest comment source GitHub Pull Request Comments Source

github pullrequest source GitHub Pull Request Source

github tag source GitHub Tag Source

google bigquery sink Google Big Query Sink

Google Calendar Source

google functions sink Google Functions Sink

google mail source Google Mail Source

google pubsub sink Google Pubsub Sink

google pubsub source Google Pubsub Source

google sheets sink Google Sheets Sink

google sheets source Google Sheets Source

google storage event based source Google Storage Event-based Source

google storage sink Google Storage Sink

google storage source Google Storage Source

graphql sink GraphQL Sink

has header filter action Has Header Filter Action

header matches filter action Header Matches Filter Action

hoist field action Hoist Field Action

Secured HTTP Sink

HTTP Secured Source

infinispan sink Infinispan Sink

infinispan source Infinispan Source

insert field action Insert Field Action

insert header action Insert Header Action

is tombstone filter action Is Tombstone Filter Action

jira add comment sink Jira Add Comment Sink

jira add issue sink Jira Add Issue Sink

jira oauth source Jira oauth Source

jira source Jira Source

jira transition issue sink Jira Transition Issue Sink

jira update issue sink Jira Update Issue Sink

jms amqp 10 sink JMS - AMQP 1.0 Sink

jms amqp 10 source JMS - AMQP 1.0 Source

jms apache artemis sink JMS - Apache Artemis Sink

jms apache artemis source JMS - Apache Artemis Source

jms ibm mq sink JMS - IBM MQ Sink

jms ibm mq source JMS - IBM MQ Source

jms pooled apache artemis sink JMS Pooled - Apache Artemis Sink

jms pooled apache artemis source JMS Pooled - Apache Artemis Source

jolt transformation action Jolt Transformation Action

jslt action JSLT Action

json deserialize action Json Deserialize Action

json patch action Json Patch Action

json schema validator action Json Schema Validator Action

json serialize action Json Serialize Action

jsonata action Jsonata Action

kafka apicurio registry not secured sink Kafka Not Secured with Apicurio Registry Sink

kafka apicurio registry not secured source Kafka Not Secured with Apicurio Registry Source

kafka azure schema registry sink Azure Kafka through Eventhubs with Azure Schema Registry Sink

kafka azure schema registry source Azure Kafka through Eventhubs with Azure Schema Registry Source

kafka batch apicurio registry not secured source Kafka Batch Not Secured with Apicurio Registry Source

kafka batch apicurio registry source Kafka Batch with Apicurio Registry secured with Keycloak Source

kafka batch azure schema registry source Azure Kafka Batch through Eventhubs with Azure Schema Registry Source

kafka batch manual commit action Kafka Batch Manual Commit Action

kafka batch not secured source Kafka Batch Not Secured Source

kafka batch scram source Kafka Batch Scram Source

kafka batch source Kafka Batch Source

kafka batch ssl source Kafka Batch SSL Source

kafka manual commit action Kafka Manual Commit Action

kafka not secured apicurio registry json source Kafka not secured with Apicurio Registry secured with Keycloak for JSON schema support Source

kafka not secured apicurio registry sink Kafka Not Secured with Apicurio Registry secured with Keycloak Sink

kafka not secured apicurio registry source Kafka not secured with Apicurio Registry secured with Keycloak Source

kafka not secured sink Kafka Not Secured Sink

kafka not secured source Kafka Not Secured Source

kafka scram sink Kafka Scram Sink

kafka scram source Kafka Scram Source

kafka sink Kafka Sink

kafka source Kafka Source

kafka ssl sink Kafka SSL Sink

kafka ssl source Kafka SSL Source

kubernetes namespaces source Kubernetes Namespaces Source

kubernetes nodes source Kubernetes Nodes Source

kubernetes pods source Kubernetes Pods Source

log action Log Action

log sink Log Sink

mail imap source Mail IMAP Source

mail sink Mail Sink

mariadb sink MariaDB Sink

mariadb source MariaDB Source

mask field action Mask Fields Action

message timestamp router action Message Timestamp Router Action

minio sink Minio Sink

minio source Minio Source

mongodb changes stream source MongoDB Changes Stream Source

mongodb sink MongoDB Sink

mongodb source MongoDB Source

mqtt sink MQTT Sink

mqtt source MQTT Source

mqtt5 sink MQTT v5 Sink

mqtt5 source MQTT 5 Source

ms exchange online imap oauth source Microsoft Exchange IMAP OAuth2 Source

mustache template action Mustache Template Action

mvel template action Mvel Template Action

mysql sink MySQL Sink

mysql source MySQL Source

nats sink NATS Sink

nats source NATS Source

nominatim geocode action Nominatim GeoCode Action

ogcapi features action OGC Api Feature Get Item Action

opensearch index sink OpenSearch Index Sink

OpenSearch Search Source

oracle database sink Oracle Database Sink

oracle database source Oracle Database Source

pdf action PDF Action

postgresql sink PostgreSQL Sink

postgresql source PostgreSQL Source

predicate filter action Predicate Filter Action

protobuf deserialize action Protobuf Deserialize Action

protobuf serialize action Protobuf Serialize Action

pulsar sink Pulsar Sink

pulsar source Pulsar Source

redis sink Redis Sink

redis source Redis Source

regex router action Regex Router Action

replace field action Replace Field Action

resolve pojo schema action Resolve Schema Action

rest openapi sink REST OpenAPI Sink

salesforce composite upsert sink Salesforce composite upsert Sink

salesforce create sink Salesforce Create Sink

salesforce delete sink Salesforce Delete Sink

salesforce source Salesforce Source

salesforce update sink Salesforce Update Sink

scp sink SCP Sink

set body action Set Body Action

set kafka key action Set Kafka Key Action

sftp sink SFTP Sink

sftp source SFTP Source

simple filter action Simple Filter Action

slack sink Slack Sink

slack source Slack Source

snowflake sink Snowflake Sink

snowflake source Snowflake Source

splunk hec sink Splunk HEC Sink

splunk sink Splunk Sink

splunk source Splunk Source

spring rabbitmq sink RabbitMQ Sink

spring rabbitmq source RabbitMQ Source

sqlserver sink Microsoft SQL Server Sink

sqlserver source Microsoft SQL Server Source

ssh sink SSH Sink

ssh source SSH Source

string template action String Template Action

Telegram Source

throttle action Throttle Action

timer source Timer Source

timestamp router action Timestamp Router Action

topic name matches filter action Kafka Topic Name Matches Filter Action

Twitter Direct Message Source

Twitter Search Source

Twitter Timeline Source

value to key action Value to Key Action

velocity template action Velocity Template Action

webhook source Webhook Source

wttrin source wttr.in Source

xj identity action XJ Identity Action

xj template action XJ Template Action

Kamelets Developer Guide