Connectors
An integration in Weik.io connects to other systems with Camel's components and kamelets. This page lists the 388 components and 250 kamelets of Camel 4.22.1, the default Camel version of Weik.io 2026.2.
All connectors
638 connectors
No connector matches. Camel can still reach the system through a jar from Maven, as the next section shows.
Components
- A2A a2a: A2A endpoint for agent-to-agent communication.
- ActiveMQ 5.x activemq: Send messages to (or consume from) Apache ActiveMQ 5.x. This component extends the Camel JMS component.
- ActiveMQ 6.x activemq6: Send messages to (or consume from) Apache ActiveMQ 6.x. This component extends the Camel JMS component.
- AI Tool ai-tool: Framework-agnostic consumer endpoint that registers a Camel route as an LLM tool in the shared AiToolRegistry.
- AMQP amqp: Messaging with AMQP protocol using Apache Qpid Client.
- ArangoDb arangodb: Perform operations on ArangoDb when used as a Document Database, or as a Graph Database.
- AS2 as2: Transfer data securely and reliably using the AS2 protocol (RFC4130).
- Asterisk asterisk: Interact with Asterisk PBX Server (VoIP).
- Atmosphere Websocket atmosphere-websocket: Expose WebSocket endpoints using the Atmosphere framework.
- Atom atom: Poll Atom RSS feeds.
- Avro RPC avro: Produce or consume Apache Avro RPC services.
- AWS Bedrock Agent Runtime aws-bedrock-agent-runtime: Invoke Model of AWS Bedrock Agent Runtime service.
- AWS Bedrock Agent aws-bedrock-agent: Operate on AWS Bedrock through its Agent.
- AWS Bedrock aws-bedrock: Invoke Model of AWS Bedrock service.
- AWS CloudTrail aws-cloudtrail: Consume events from Amazon CloudTrail using AWS SDK version 2.x.
- AWS Config Service aws-config: Manage AWS Config service.
- AWS Secrets Manager aws-secrets-manager: Manage secrets using AWS Secrets Manager.
- AWS Security Hub aws-security-hub: Manage and interact with AWS Security Hub for security findings.
- AWS Athena aws2-athena: Access AWS Athena.
- AWS Comprehend aws2-comprehend: Perform natural language processing using AWS Comprehend and AWS SDK version 2.x.
- AWS CloudWatch aws2-cw: Sending metrics to AWS CloudWatch.
- AWS DynamoDB aws2-ddb: Store and retrieve data from AWS DynamoDB.
- AWS DynamoDB Streams aws2-ddbstream: Receive messages from AWS DynamoDB Stream.
- AWS Elastic Compute Cloud (EC2) aws2-ec2: Manage AWS EC2 instances.
- AWS Elastic Container Service (ECS) aws2-ecs: Manage AWS ECS cluster instances.
- AWS Elastic Kubernetes Service (EKS) aws2-eks: Manage AWS EKS cluster instances.
- AWS Eventbridge aws2-eventbridge: Manage AWS EventBridge cluster instances and consume events via SQS-backed polling.
- AWS Identity and Access Management (IAM) aws2-iam: Manage AWS IAM instances.
- AWS Kinesis Firehose aws2-kinesis-firehose: Produce data to AWS Kinesis Firehose streams.
- AWS Kinesis aws2-kinesis: Consume and produce records from and to AWS Kinesis Streams.
- AWS Key Management Service (KMS) aws2-kms: Manage keys stored in AWS KMS instances.
- AWS Lambda aws2-lambda: Manage and invoke AWS Lambda functions.
- AWS MQ aws2-mq: Send messages to AWS MQ.
- AWS Managed Streaming for Apache Kafka (MSK) aws2-msk: Manage AWS MSK instances.
- AWS Polly aws2-polly: Synthesize speech using AWS Polly and AWS SDK version 2.x.
- AWS RedshiftData aws2-redshift-data: Perform operations on AWS Redshift using Redshift Data API.
- AWS Rekognition aws2-rekognition: Manage and invoke AWS Rekognition.
- AWS S3 Vectors aws2-s3-vectors: Store and query vector embeddings using AWS S3 Vectors with similarity search.
- AWS S3 Storage Service aws2-s3: Store and retrieve objects from AWS S3 Storage Service.
- AWS Simple Email Service (SES) aws2-ses: Send e-mails through AWS SES service.
- AWS Simple Notification System (SNS) aws2-sns: Send messages to AWS Simple Notification Topic.
- AWS Simple Queue Service (SQS) aws2-sqs: Send and receive messages to/from AWS SQS.
- AWS StepFunctions aws2-step-functions: Manage and invoke AWS Step functions.
- AWS Security Token Service (STS) aws2-sts: Manage AWS STS cluster instances.
- AWS Textract aws2-textract: Extract text and data from documents using AWS Textract and AWS SDK version 2.x.
- AWS Timestream aws2-timestream: Write records and execute queries on AWS time-series database.
- AWS Transcribe aws2-transcribe: Automatically convert speech to text using AWS Transcribe service.
- AWS Translate aws2-translate: Translate texts using AWS Translate and AWS SDK version 2.x.
- Azure CosmosDB azure-cosmosdb: To read and write records to the CosmosDB database on Azure cloud platform.
- Azure Event Hubs azure-eventhubs: Send and receive events to/from Azure Event Hubs using AMQP protocol.
- Azure Files azure-files: Send and receive files to Azure storage file share.
- Azure Functions azure-functions: Invoke and manage Azure Functions.
- Azure Key Vault azure-key-vault: Manage secrets and keys in Azure Key Vault Service.
- Azure ServiceBus azure-servicebus: Send and receive messages to/from Azure Service Bus.
- Azure Storage Blob Service azure-storage-blob: Store and retrieve blobs from Azure Storage Blob Service.
- Azure Storage Data Lake Service azure-storage-datalake: Sends and receives files to/from Azure Data Lake Storage.
- Azure Storage Queue Service azure-storage-queue: Stores and retrieves messages to/from Azure Storage Queue.
- Bean Validator bean-validator: Validate the message body using the Java Bean Validation API.
- Bean bean: Invoke methods of Java beans stored in Camel registry.
- Bonita bonita: Communicate with a remote Bonita BPM process engine.
- Box box: Upload, download and manage files, folders, groups, collaborations, etc. on box.com.
- Braintree braintree: Process payments using Braintree Payments.
- Browse browse: Inspect the messages received on endpoints supporting BrowsableEndpoint.
- Caffeine Cache caffeine-cache: Perform caching operations using Caffeine Cache.
- Caffeine LoadCache caffeine-loadcache: Perform caching operations using Caffeine Cache with an attached CacheLoader.
- Camunda camunda: Interact with Camunda 8 Orchestration Clusters using the Camunda Java Client.
- ChatScript chatscript: Chat with a ChatScript Server.
- Chunk chunk: Transform messages using Chunk templating engine.
- Class class: Invoke methods of Java beans specified by class name.
- ClickHouse clickhouse: Interact with ClickHouse, the high-performance columnar OLAP database, for high-throughput ingestion and OLAP queries.
- ClickUp clickup: Receives events from ClickUp.
- CM SMS Gateway cm-sms: Send SMS messages via CM SMS Gateway.
- CoAP coap+tcp: Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CoAP coap: Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CoAP coaps+tcp: Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CoAP (Secure) coaps: Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CometD cometd: Offers publish/subscribe, peer-to-peer (via a server), and RPC style messaging using the CometD/Bayeux protocol.
- CometD (Secure) cometds: Offers publish/subscribe, peer-to-peer (via a server), and RPC style messaging using the CometD/Bayeux protocol.
- Consul consul: Integrate with Consul service discovery and configuration store.
- Control Bus controlbus: Manage and monitor Camel routes.
- Couchbase couchbase: Query Couchbase databases using SQL (N1QL) queries or MapReduce Views with a poll strategy and/or perform various operations against Couchbase databases.
- CouchDB couchdb: Consume changesets for inserts, updates and deletes in a CouchDB database, as well as get, save, update and delete documents from a CouchDB database.
- Cassandra CQL cql: Integrate with Cassandra 2.0 using the CQL3 API (not the Thrift API). Based on Cassandra Java Driver provided by DataStax.
- Cron cron: A generic interface for triggering events at times specified through the Unix cron syntax.
- Crypto (JCE) crypto: Sign and verify exchanges using the Signature Service of the Java Cryptographic Extension (JCE).
- CXF cxf: Expose SOAP WebServices using Apache CXF or connect to external WebServices using CXF WS client.
- CXF-RS cxfrs: Expose JAX-RS REST services using Apache CXF or connect to external REST services using CXF REST client.
- CyberArk Vault cyberark-vault: Retrieve secrets from CyberArk Conjur Vault.
- Dapr dapr: Dapr component which interfaces with Dapr Building Blocks.
- Data Format dataformat: Use a Camel Data Format as a regular Camel Component.
- DataSet Test dataset-test: Extends the mock component by pulling messages from another endpoint on startup to set the expected message bodies.
- Dataset dataset: Provide data for load and soak testing of your Camel application.
- Debezium DB2 Connector debezium-db2: Capture changes from a DB2 database.
- Debezium MongoDB Connector debezium-mongodb: Capture changes from a MongoDB database.
- Debezium MySQL Connector debezium-mysql: Capture changes from a MySQL database.
- Debezium Oracle Connector debezium-oracle: Capture changes from an Oracle database.
- Debezium PostgreSQL Connector debezium-postgres: Capture changes from a PostgreSQL database.
- Debezium SQL Server Connector debezium-sqlserver: Capture changes from an SQL Server database.
- DFDL dfdl: Transforms fixed format data such as EDI message from/to XML using a Data Format Description Language (DFDL).
- DHIS2 dhis2: Uses the DHIS2 Java SDK to integrate Apache Camel with the DHIS2 Web API.
- Direct direct: Call another endpoint from the same Camel Context synchronously.
- Disruptor VM disruptor-vm: Provides asynchronous SEDA behavior using LMAX Disruptor.
- Disruptor disruptor: Provides asynchronous SEDA behavior using LMAX Disruptor.
- Deep Java Library djl: Infer Deep Learning models from message exchanges data using Deep Java Library (DJL).
- DNS dns: Perform DNS queries using DNSJava.
- Docker docker: Manage Docker containers.
- Docling docling: Process documents using Docling library for parsing and conversion.
- Drill drill: Perform queries against an Apache Drill cluster.
- Dropbox dropbox: Upload, download and manage files, folders, groups, collaborations, etc on Dropbox.
- DuckDB duckdb: Interact with DuckDB, the in-process analytical SQL database, for embedded analytics workloads.
- Dynamic Router Control dynamic-router-control: The Dynamic Router control endpoint for operations that allow routing participants to subscribe or unsubscribe to participate in dynamic message routing.
- Dynamic Router dynamic-router: The Dynamic Router component routes exchanges to recipients, and the recipients (and their rules) may change at runtime.
- Ehcache ehcache: Perform caching operations using Ehcache.
- Elasticsearch Low level Rest Client elasticsearch-rest-client: Perform queries and other operations on Elasticsearch or OpenSearch (uses low-level client).
- Elasticsearch elasticsearch: Send requests to Elasticsearch via Java Client API.
- Event event: Subscribe to Camel internal events such as route started/stopped and exchange completed/failed.
- Exec exec: Execute commands on the underlying operating system.
- FHIR fhir: Exchange information in the healthcare domain using the FHIR (Fast Healthcare Interoperability Resources) standard.
- File Watch file-watch: Get notified about file events in a directory using java.nio.file.WatchService.
- File file: Read and write files.
- Flatpack flatpack: Parse fixed width and delimited files using the FlatPack library.
- Flink flink: Send DataSet jobs to an Apache Flink cluster.
- Flowable flowable: Send and receive messages from the Flowable BPMN and CMMN engines.
- FOP fop: Render messages into PDF and other output formats supported by Apache FOP.
- Freemarker freemarker: Transform messages using FreeMarker templates.
- FTP ftp: Upload and download files to/from FTP servers.
- FTPS ftps: Upload and download files to/from FTP servers supporting the FTPS protocol.
- Geocoder geocoder: Find geocodes (latitude and longitude) for a given address or the other way round.
- Git git: Perform operations on git repositories.
- GitHub2 github2: Interact with the GitHub API.
- Google BigQuery Standard SQL google-bigquery-sql: Access Google Cloud BigQuery service using SQL queries.
- Google BigQuery google-bigquery: Google BigQuery data warehouse for analytics.
- Google Calendar Stream google-calendar-stream: Poll for changes in a Google Calendar.
- Google Calendar google-calendar: Perform various operations on a Google Calendar.
- Google Drive google-drive: Manage files in Google Drive.
- Google Firestore google-firestore: Store and retrieve data from Google Cloud Firestore NoSQL database.
- Google Cloud Functions google-functions: Manage and invoke Google Cloud Functions.
- Google Mail Stream google-mail-stream: Poll for incoming messages in Google Mail.
- Google Mail google-mail: Manage messages in Google Mail.
- Google Pubsub google-pubsub: Send and receive messages to/from Google Cloud Platform PubSub Service.
- Google Secret Manager google-secret-manager: Manage Google Secret Manager Secrets.
- Google Sheets Stream google-sheets-stream: Poll for changes in Google Sheets.
- Google Sheets google-sheets: Manage spreadsheets in Google Sheets.
- Google Cloud Speech To Text google-speech-to-text: Transcribe audio to text using Google Cloud Speech-to-Text API.
- Google Storage google-storage: Store and retrieve objects from Google Cloud Storage Service using the google-cloud-storage library.
- Google Cloud Text To Speech google-text-to-speech: Synthesize speech from text using the Google Cloud Text-to-Speech API.
- Google Vertex AI google-vertexai: Interact with Google Cloud Vertex AI generative models.
- Google Cloud Vision google-vision: Detect labels, text, faces, logos and more on images through Google Cloud Vision API.
- GraphQL graphql: Send GraphQL queries and mutations to external systems.
- gRPC grpc: Expose gRPC endpoints and access external gRPC endpoints.
- HashiCorp Vault hashicorp-vault: Manage secrets in HashiCorp Vault Service.
- Hazelcast Instance hazelcast-instance: Consume join/leave events of a cache instance in a Hazelcast cluster.
- Hazelcast List hazelcast-list: Perform operations on Hazelcast distributed list.
- Hazelcast Map hazelcast-map: Perform operations on Hazelcast distributed map.
- Hazelcast Multimap hazelcast-multimap: Perform operations on Hazelcast distributed multimap.
- Hazelcast PN Counter hazelcast-pncounter: Increment, decrement, get, etc. operations on a Hazelcast PN Counter (CRDT counter).
- Hazelcast Queue hazelcast-queue: Perform operations on Hazelcast distributed queue.
- Hazelcast Replicated Map hazelcast-replicatedmap: Perform operations on Hazelcast replicated map.
- Hazelcast Ringbuffer hazelcast-ringbuffer: Perform operations on Hazelcast distributed ringbuffer.
- Hazelcast SEDA hazelcast-seda: Asynchronously send/receive Exchanges between Camel routes running on potentially distinct JVMs/hosts backed by Hazelcast BlockingQueue.
- Hazelcast Set hazelcast-set: Perform operations on Hazelcast distributed set.
- Hazelcast Topic hazelcast-topic: Send and receive messages to/from Hazelcast distributed topic.
- HTTP http: Send requests to external HTTP servers using Apache HTTP Client 5.x.
- HTTPS (Secure) https: Send requests to external HTTP servers using Apache HTTP Client 5.x.
- Hugging Face huggingface: Integration with Hugging Face's Model Hub by using the Deep Java Library (DJL) Python bridge.
- Huawei Distributed Message Service (DMS) hwcloud-dms: To integrate with a fully managed, high-performance message queuing service on Huawei Cloud.
- Huawei Cloud Face Recognition Service (FRS) hwcloud-frs: Face Recognition Service (FRS) is an intelligent service that uses computers to process, analyze, and understand facial images based on human facial features.
- Huawei FunctionGraph hwcloud-functiongraph: To call serverless functions on Huawei Cloud.
- Huawei Identity and Access Management (IAM) hwcloud-iam: To securely manage users on Huawei Cloud.
- Huawei Cloud Image Recognition hwcloud-imagerecognition: To identify objects, scenes, and concepts in images on Huawei Cloud.
- Huawei Object Storage Service (OBS) hwcloud-obs: To provide stable, secure, efficient, and easy-to-use cloud storage service on Huawei Cloud.
- Huawei Simple Message Notification (SMN) hwcloud-smn: To broadcast messages and connect cloud services through notifications on Huawei Cloud.
- IBM Cloud Object Storage ibm-cos: Store and retrieve objects from IBM Cloud Object Storage.
- IBM Secrets Manager ibm-secrets-manager: Manage secrets in IBM Secrets Manager Service.
- IBM Watson Discovery ibm-watson-discovery: Perform document understanding and search using IBM Watson Discovery.
- IBM Watson Language ibm-watson-language: Perform natural language processing using IBM Watson Natural Language Understanding.
- IBM Watson Speech to Text ibm-watson-speech-to-text: Convert speech audio to text using IBM Watson Speech to Text.
- IBM Watson Text to Speech ibm-watson-text-to-speech: Convert text to natural-sounding speech using IBM Watson Text to Speech.
- IBM watsonx.ai ibm-watsonx-ai: Interact with IBM watsonx.ai foundation models for text generation, chat, embeddings, and more.
- IBM watsonx.data ibm-watsonx-data: Interact with IBM watsonx.data lakehouse for catalog, schema, table, and engine management.
- Iggy iggy: Send and receive messages with the Apache Iggy streaming platform.
- Ignite Cache ignite-cache: Perform cache operations on an Ignite cache or consume changes from a continuous query.
- Ignite Compute ignite-compute: Run compute operations on an Ignite cluster.
- Ignite Events ignite-events: Receive events from an Ignite cluster by creating a local event listener.
- Ignite ID Generator ignite-idgen: Interact with Ignite Atomic Sequences and ID Generators.
- Ignite Messaging ignite-messaging: Send and receive messages from an Ignite topic.
- Ignite Queues ignite-queue: Interact with Ignite Queue data structures.
- Ignite Sets ignite-set: Interact with Ignite Set data structures.
- IMAP imap: Send and receive emails using imap, pop3 and smtp protocols.
- IMAPS (Secure) imaps: Send and receive emails using imap, pop3 and smtp protocols.
- Infinispan Embedded infinispan-embedded: Read and write from/to Infinispan distributed key/value store and data grid.
- Infinispan infinispan: Read and write from/to Infinispan distributed key/value store and data grid.
- InfluxDB influxdb: Interact with InfluxDB v1, a time series database.
- InfluxDB2 influxdb2: Interact with InfluxDB v2, a time series database.
- JCache jcache: Perform caching operations against JSR107/JCache.
- JCR jcr: Read and write nodes to/from a JCR compliant content repository.
- JDBC jdbc: Access databases through SQL and JDBC.
- Jetty jetty: Expose HTTP endpoints using Jetty 12.
- JGroups raft jgroups-raft: Exchange messages with JGroups-raft clusters.
- JGroups jgroups: Exchange messages with JGroups clusters.
- Jira jira: Interact with JIRA issue tracker.
- JMS jms: Send and receive messages to/from JMS message brokers.
- JMX jmx: Receive JMX notifications.
- JOLT jolt: JSON to JSON transformation using JOLT.
- JOOQ jooq: Store and retrieve Java objects from an SQL database using JOOQ.
- JPA jpa: Store and retrieve Java objects from databases using Java Persistence API (JPA).
- JSLT jslt: Query or transform JSON payloads using JSLT.
- JSON Schema Validator json-validator: Validate JSON payloads using NetworkNT JSON Schema.
- JSONata jsonata: Transforms JSON payload using JSONata transformation.
- JT400 jt400: Exchanges messages with an IBM i system using data queues, message queues, or program call. IBM i is the replacement for AS/400 and iSeries servers.
- JTE jte: Transform messages using a Java based template engine (JTE).
- Kafka kafka: Send and receive messages to/from an Apache Kafka broker.
- Kamelet kamelet: To call Kamelets.
- Keycloak keycloak: Manage Keycloak instances via Admin API.
- Knative knative: Send and receive events from Knative.
- KServe kserve: Provide access to AI model servers with the KServe standard to run inference with remote models.
- Kubernetes ConfigMap kubernetes-config-maps: Perform operations on Kubernetes ConfigMaps and get notified on ConfigMaps changes.
- Kubernetes Cronjob kubernetes-cronjob: Perform operations on Kubernetes CronJob.
- Kubernetes Custom Resources kubernetes-custom-resources: Perform operations on Kubernetes Custom Resources and get notified on Deployment changes.
- Kubernetes Deployments kubernetes-deployments: Perform operations on Kubernetes Deployments and get notified on Deployment changes.
- Kubernetes Event kubernetes-events: Perform operations on Kubernetes Events and get notified on Events changes.
- Kubernetes HPA kubernetes-hpa: Perform operations on Kubernetes Horizontal Pod Autoscalers (HPA) and get notified on HPA changes.
- Kubernetes Job kubernetes-job: Perform operations on Kubernetes Jobs.
- Kubernetes Namespaces kubernetes-namespaces: Perform operations on Kubernetes Namespaces and get notified on Namespace changes.
- Kubernetes Nodes kubernetes-nodes: Perform operations on Kubernetes Nodes and get notified on Node changes.
- Kubernetes Persistent Volume Claim kubernetes-persistent-volumes-claims: Perform operations on Kubernetes Persistent Volumes Claims and get notified on Persistent Volumes Claim changes.
- Kubernetes Persistent Volume kubernetes-persistent-volumes: Perform operations on Kubernetes Persistent Volumes and get notified on Persistent Volume changes.
- Kubernetes Pods kubernetes-pods: Perform operations on Kubernetes Pods and get notified on Pod changes.
- Kubernetes Replication Controller kubernetes-replication-controllers: Perform operations on Kubernetes Replication Controllers and get notified on Replication Controllers changes.
- Kubernetes Resources Quota kubernetes-resources-quota: Perform operations on Kubernetes Resources Quotas.
- Kubernetes Secrets kubernetes-secrets: Perform operations on Kubernetes Secrets.
- Kubernetes Service Account kubernetes-service-accounts: Perform operations on Kubernetes Service Accounts.
- Kubernetes Services kubernetes-services: Perform operations on Kubernetes Services and get notified on Service changes.
- Kudu kudu: Interact with Apache Kudu, a free and open source column-oriented data store of the Apache Hadoop ecosystem.
- LangChain4j Agent langchain4j-agent: LangChain4j Agent component.
- LangChain4j Chat langchain4j-chat: LangChain4j Chat component.
- LangChain4j Embeddings langchain4j-embeddings: LangChain4j Embeddings.
- LangChain4j Embedding Store langchain4j-embeddingstore: Perform operations on the LangChain4jEmbeddingStores.
- LangChain4j Web Search langchain4j-web-search: LangChain4j Web Search Engine.
- Language language: Execute scripts in any of the languages supported by Camel.
- LDAP ldap: Perform searches on LDAP servers.
- LDIF ldif: Perform updates on an LDAP server from an LDIF body content.
- Log Data log: Prints data from the routed message (such as body and headers) to the logger.
- Printer lpr: Send print jobs to printers.
- Lucene lucene: Perform inserts or queries against Apache Lucene databases.
- Lumberjack lumberjack: Receive logs messages using the Lumberjack protocol.
- MapStruct mapstruct: Type Conversion using MapStruct.
- Master master: Have only a single consumer in a cluster consuming from a given endpoint, with automatic failover if the JVM dies.
- Metrics metrics: Collect various metrics directly from Camel routes using the DropWizard metrics library.
- Micrometer micrometer: Collect various metrics directly from Camel routes using the Micrometer library.
- OPC UA Browser milo-browse: Connect to OPC UA servers using the binary protocol for browsing the node tree.
- OPC UA Client milo-client: Connect to OPC UA servers using the binary protocol for acquiring telemetry data.
- OPC UA Server milo-server: Make telemetry data available as an OPC UA server.
- Milvus milvus: Perform operations on the Milvus Vector Database.
- MINA SFTP mina-sftp: Upload and download files to/from SFTP servers using Apache MINA SSHD.
- Mina mina: Socket level networking using TCP or UDP with Apache Mina 2.x.
- Minio minio: Store and retrieve objects from Minio Storage Service using Minio SDK.
- MLLP mllp: Communicate with external systems using the MLLP protocol.
- Mock mock: Test routes and mediation rules using mocks.
- MongoDB GridFS mongodb-gridfs: Interact with MongoDB GridFS.
- MongoDB mongodb: Perform operations on MongoDB documents and collections.
- Mustache mustache: Transform messages using a Mustache template.
- MVEL mvel: Transform messages using an MVEL template.
- MyBatis Bean mybatis-bean: Perform queries, inserts, updates or deletes in a relational database using MyBatis.
- MyBatis mybatis: Performs a query, poll, insert, update or delete in a relational database using MyBatis.
- Nats nats: Send and receive messages from NATS messaging system.
- Neo4j neo4j: Perform operations on the Neo4j Graph Database.
- Netty HTTP netty-http: Netty HTTP server and client using the Netty 4.x.
- Netty netty: Socket level networking using TCP or UDP with Netty 4.x.
- OAI-PMH oaipmh: Harvest metadata using OAI-PMH protocol.
- Once once: Trigger a single message only once at startup (useful for development and testing purposes).
- OpenAI openai: OpenAI endpoint for chat completion, Responses API, embeddings, audio transcription, audio translation, and text-to-speech.
- OpenSearch opensearch: Send requests to OpenSearch via Java Client API.
- OpenShift Build Config openshift-build-configs: Perform operations on OpenShift Build Configs.
- OpenShift Builds openshift-builds: Perform operations on OpenShift Builds.
- OpenShift Deployment Configs openshift-deploymentconfigs: Perform operations on OpenShift Deployment Configs and get notified on Deployment Config changes.
- OpenStack Cinder openstack-cinder: Access data in OpenStack Cinder block storage.
- OpenStack Glance openstack-glance: Manage VM images and metadata definitions in OpenStack Glance.
- OpenStack Keystone openstack-keystone: Access OpenStack Keystone for API client authentication, service discovery and distributed multi-tenant authorization.
- OpenStack Neutron openstack-neutron: Access OpenStack Neutron for network services.
- OpenStack Nova openstack-nova: Access OpenStack to manage compute resources.
- OpenStack Swift openstack-swift: Access OpenStack Swift object/blob store.
- OpenTelemetry Metrics opentelemetry-metrics: Camel metrics based on the Camel Telemetry spec.
- OptaPlanner optaplanner: Solve planning problems with OptaPlanner.
- Paho MQTT 5 paho-mqtt5: Communicate with MQTT message brokers using Eclipse Paho MQTT v5 Client.
- PDF pdf: Create, modify or extract content from PDF documents.
- PostgreSQL Replication Slot pg-replication-slot: Poll for PostgreSQL Write-Ahead Log (WAL) records using Streaming Replication Slots.
- PostgreSQL Event pgevent: Send and receive PostgreSQL events via LISTEN and NOTIFY commands.
- PGVector pgvector: Perform operations on the PostgreSQL pgvector Vector Database.
- Pinecone pinecone: Perform operations on the Pinecone Vector Database.
- Platform HTTP platform-http: Expose HTTP endpoints using the HTTP server available in the current platform.
- PLC4X plc4x: Read and write to PLC devices.
- POP3 pop3: Send and receive emails using imap, pop3 and smtp protocols.
- POP3S pop3s: Send and receive emails using imap, pop3 and smtp protocols.
- PQC Algorithms pqc: Post Quantum Cryptography Signature and Verification component.
- PubNub pubnub: Send and receive messages to/from PubNub data stream network for connected devices.
- Pulsar pulsar: Send and receive messages from/to Apache Pulsar messaging system.
- Qdrant qdrant: Perform operations on the Qdrant Vector Database.
- Quartz quartz: Schedule sending of messages using the Quartz 2.x scheduler.
- QuickFix quickfix: Open a Financial Interchange (FIX) session using an embedded QuickFix/J engine.
- Reactive Streams reactive-streams: Exchange messages with reactive stream processing libraries compatible with the reactive streams standard.
- Ref ref: Route messages to an endpoint looked up dynamically by name in the Camel Registry.
- REST API rest-api: Expose OpenAPI Specification of the REST services defined using Camel REST DSL.
- REST OpenApi rest-openapi: To call and expose REST services using OpenAPI specification as contract.
- REST rest: Expose REST services or call external REST services.
- Robot Framework robotframework: Pass camel exchanges to acceptance test written in Robot DSL.
- RocketMQ rocketmq: Send and receive messages from RocketMQ cluster.
- RSS rss: Poll RSS feeds.
- Saga saga: Execute custom actions within a route using the Saga EIP.
- Salesforce salesforce: Communicate with Salesforce using Java DTOs.
- SAP NetWeaver sap-netweaver: Send requests to SAP NetWeaver Gateway using HTTP.
- Scheduler scheduler: Generate messages in specified intervals using java.util.concurrent.ScheduledExecutorService.
- Schematron schematron: Validate XML payload using the Schematron Library.
- SCP scp: Copy files to/from remote hosts using the secure copy protocol (SCP).
- SEDA seda: Asynchronously call another endpoint from any Camel Context in the same JVM.
- ServiceNow servicenow: Interact with ServiceNow via its REST API.
- Servlet servlet: Serve HTTP requests by a Servlet.
- SFTP sftp: Upload and download files to/from SFTP servers.
- Shell shell: Camel Shell component.
- Simple JMS sjms: Send and receive messages to/from a JMS Queue or Topic using plain JMS 1.x API.
- Simple JMS2 sjms2: Send and receive messages to/from a JMS Queue or Topic using plain JMS 2.x API.
- Slack slack: Send and receive messages to/from Slack.
- SMB smb: Read and write files to Server Message Block (SMB) file shares.
- Smooks smooks: Use Smooks to transform, route, and bind both XML and non-XML data, including EDI, CSV, JSON, and YAML.
- SMPP smpp: Send and receive SMS messages using a SMSC (Short Message Service Center).
- SMPP (Secure) smpps: Send and receive SMS messages using a SMSC (Short Message Service Center).
- SMTP smtp: Send and receive emails using imap, pop3 and smtp protocols.
- SMTPS smtps: Send and receive emails using imap, pop3 and smtp protocols.
- SNMP snmp: Receive traps and poll SNMP (Simple Network Management Protocol) capable devices.
- Solr solr: Perform operations against Apache Lucene Solr.
- Splunk HEC splunk-hec: The splunk component allows publishing events in Splunk using the HTTP Event Collector.
- Spring AI Chat spring-ai-chat: Perform chat operations using Spring AI.
- Spring AI Embeddings spring-ai-embeddings: Spring AI Embeddings.
- Spring AI Image spring-ai-image: Spring AI Image Generation.
- Spring AI Vector Store spring-ai-vector-store: Spring AI Vector Store.
- Spring Batch spring-batch: Send messages to Spring Batch for further processing.
- Spring Event spring-event: Listen for Spring Application Events.
- Spring JDBC spring-jdbc: Access databases through SQL and JDBC with Spring Transaction support.
- Spring LDAP spring-ldap: Perform searches in LDAP servers using filters as the message payload.
- Spring RabbitMQ spring-rabbitmq: Send and receive messages from RabbitMQ using the Spring RabbitMQ client.
- Spring Redis spring-redis: Send and receive messages from Redis.
- Spring WebService spring-ws: Access external web services as a client or expose your own web services.
- SQL Stored Procedure sql-stored: Perform SQL queries as a JDBC Stored Procedures using Spring JDBC.
- SQL sql: Perform SQL queries using Spring JDBC.
- SSH ssh: Execute commands on remote hosts using SSH.
- StAX stax: Process XML payloads by a SAX ContentHandler.
- Stitch stitch: Stitch is a cloud ETL service that integrates various data sources into a central data warehouse through various integrations.
- Stream stream: Read from system-in and write to system-out and system-err streams.
- String Template string-template: Transform messages using StringTemplate engine.
- Stripe stripe: Interact with the Stripe payment platform.
- Stub stub: Stub out any physical endpoints while in development or testing.
- Tahu Edge Node / Device tahu-edge: Sparkplug B Edge Node and Device support over MQTT using Eclipse Tahu.
- Tahu Host Application tahu-host: Sparkplug B Host Application support over MQTT using Eclipse Tahu.
- Telegram telegram: Send and receive messages using the Telegram Bot API.
- TensorFlow Serving tensorflow-serving: Provide access to TensorFlow Serving model servers to run inference with TensorFlow saved models remotely.
- Thrift thrift: Call and expose remote procedures (RPC) with Apache Thrift data format and serialization mechanism.
- Thymeleaf thymeleaf: Transform messages using a Thymeleaf template.
- Tika tika: Parse documents and extract metadata and text using Apache Tika.
- Timer timer: Generate messages in specified intervals using java.util.Timer.
- Twilio twilio: Interact with Twilio REST APIs using Twilio Java SDK.
- Twitter Direct Message twitter-directmessage: Send and receive Twitter direct messages.
- Twitter Search twitter-search: Access Twitter Search.
- Twitter Timeline twitter-timeline: Send tweets and receive tweets from user's timeline.
- Undertow undertow: Expose HTTP and WebSocket endpoints and access external HTTP/WebSocket servers.
- Validator validator: Validate the payload using XML Schema and JAXP Validation.
- Velocity velocity: Transform messages using a Velocity template.
- Vert.x HTTP Client vertx-http: Send requests to external HTTP servers using Vert.x.
- Vert.x WebSocket vertx-websocket: Expose WebSocket endpoints and connect to remote WebSocket servers using Vert.x.
- Vert.x vertx: Send and receive messages to/from Vert.x Event Bus.
- Wasm wasm: Invoke Wasm functions.
- Weather weather: Poll the weather information from Open Weather Map.
- Weaviate weaviate: Perform operations on the Weaviate Vector Database.
- Web3j Ethereum Blockchain web3j: Interact with Ethereum nodes using web3j client API.
- Webhook webhook: Expose webhook endpoints to receive push notifications for other Camel components.
- WhatsApp whatsapp: Send messages to WhatsApp.
- WordPress wordpress: Manage posts and users using the WordPress API.
- Workday workday: Detect and parse documents using Workday.
- XChange xchange: Access market data and trade on Bitcoin and Altcoin exchanges.
- XJ xj: Transform JSON and XML messages using an XSLT.
- XML Security Sign xmlsecurity-sign: Sign XML payloads using the XML signature specification.
- XML Security Verify xmlsecurity-verify: Verify XML payloads using the XML signature specification.
- XMPP xmpp: Send and receive messages to/from an XMPP chat server.
- XQuery xquery: Query and/or transform XML payloads using XQuery and Saxon.
- XSLT Saxon xslt-saxon: Transform XML payloads using an XSLT template using Saxon.
- XSLT xslt: Transforms XML payload using an XSLT template.
- Zendesk zendesk: Manage Zendesk tickets, users, organizations, etc.
- ZooKeeper Master zookeeper-master: Have only a single consumer in a cluster consuming from a given endpoint, with automatic failover if the JVM dies.
- ZooKeeper zookeeper: Manage ZooKeeper clusters.
Kamelets
A kamelet is a ready-made route template for one system, used as a source, a sink or an action in your routes and in event sources and channels.
- Avro Deserialize Action kamelet:avro-deserialize-action Deserialize payload to Avro.
- Avro Serialize Action kamelet:avro-serialize-action Serialize payload to Avro.
- AWS Bedrock Agent Runtime Sink kamelet:aws-bedrock-agent-runtime-sink Send data for invoking a knowledge base from AWS Bedrock.
- AWS Bedrock Text Sink kamelet:aws-bedrock-text-sink Send data for invoking a text model of Amazon Bedrock.
- AWS Cloudtrail Source kamelet:aws-cloudtrail-source Receive data from an AWS Cloudtrail.
- AWS CloudWatch Metrics Sink kamelet:aws-cloudwatch-sink Send data to Amazon CloudWatch metrics.
- AWS Comprehend Sink kamelet:aws-comprehend-sink Send data to AWS Comprehend for natural language processing.
- AWS DynamoDB Sink kamelet:aws-ddb-sink Send data to Amazon DynamoDB. The sent data inserts, updates, or deletes an item on the specified AWS DynamoDB table.
- AWS DynamoDB Streams Source kamelet:aws-ddb-streams-source Receive events from Amazon DynamoDB Streams.
- AWS EC2 Sink kamelet:aws-ec2-sink Check the status of EC2 instances.
- AWS Eventbridge Sink kamelet:aws-eventbridge-sink Send events to an Amazon Eventbridge Eventbus. In the headers, you can set the resources-arn / ce-resources-arn property to specify the ARN of resources related to the event. In the headers, you can set the detail-type / ce-detail-type property to specify the detail type related to the event. In the headers, you can set the event-source / ce-event-source property to specify the event source related to the event. If you do not set the property in the header, the Kamelet uses the given Kamelet properties as a default.
- AWS Kinesis Firehose Sink kamelet:aws-kinesis-firehose-sink Send message to an AWS Kinesis Firehose Stream.
- AWS Kinesis Sink kamelet:aws-kinesis-sink Send data to AWS Kinesis.
- AWS Kinesis Source kamelet:aws-kinesis-source Receive data from AWS Kinesis.
- AWS Lambda Sink kamelet:aws-lambda-sink Send a payload to an AWS Lambda function.
- AWS Polly Sink kamelet:aws-polly-sink Synthesize speech from text using AWS Polly.
- AWS Redshift Sink kamelet:aws-redshift-sink Send data to an AWS Redshift Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- AWS Redshift Source kamelet:aws-redshift-source Query data from an AWS Redshift Database.
- AWS S3 Event Based Source kamelet:aws-s3-event-based-source Receive data from AWS SQS subscribed to Eventbridge Bus reporting events related to an S3 bucket or multiple buckets.
- AWS S3 Sink kamelet:aws-s3-sink Upload data to an Amazon S3 Bucket.
- AWS S3 Source kamelet:aws-s3-source Receive data from an Amazon S3 Bucket.
- AWS S3 Streaming upload Sink kamelet:aws-s3-streaming-upload-sink Upload data to AWS S3 in streaming upload mode.
- AWS Secrets Manager Sink kamelet:aws-secrets-manager-sink Create a secret in AWS Secrets Manager.
- AWS SES Sink kamelet:aws-ses-sink Send email through the Amazon Simple Email Service (SES).
- AWS SNS FIFO Sink kamelet:aws-sns-fifo-sink Send message to an AWS SNS FIFO Topic.
- AWS SNS Sink kamelet:aws-sns-sink Send message to an Amazon Simple Notification Service (SNS) topic.
- AWS SQS Batch Sink kamelet:aws-sqs-batch-sink Send Batch message to an AWS SQS Queue.
- AWS SQS FIFO Sink kamelet:aws-sqs-fifo-sink Send message to an AWS SQS FIFO Queue.
- AWS SQS Sink kamelet:aws-sqs-sink Send messages to an Amazon Simple Queue Service (SQS) queue.
- AWS SQS Source kamelet:aws-sqs-source Receive data from AWS SQS.
- AWS STS Assume Role Action kamelet:aws-sts-assume-role-action Assume a role through STS.
- AWS Timestream Query Sink kamelet:aws-timestream-query-sink Query an AWS Timestream Database.
- AWS Translate Action kamelet:aws-translate-action Translate a text in a specific language.
- Azure CosmosDB Sink kamelet:azure-cosmosdb-sink Send Data to an Azure CosmosDB instance.
- Azure CosmosDB Source kamelet:azure-cosmosdb-source Consume Changes from a CosmosDB instance.
- Azure Eventhubs Sink kamelet:azure-eventhubs-sink Send events to Azure Event Hubs.
- Azure Eventhubs Source kamelet:azure-eventhubs-source Receive events from Azure Event Hubs.
- Azure Function Sink kamelet:azure-functions-sink Forward data to an Azure Function.
- Azure Servicebus Sink kamelet:azure-servicebus-sink Send Messages to Azure Servicebus.
- Azure Servicebus Source kamelet:azure-servicebus-source Consume Messages from Azure Servicebus.
- Azure Storage Blob Append Sink kamelet:azure-storage-blob-append-sink Upload data in append mode to Azure Storage Blob.
- Azure Storage Blob Changefeed Source kamelet:azure-storage-blob-changefeed-source Consume events from an Azure Storage Blob change feed.
- Azure Storage Blob Event-based Source kamelet:azure-storage-blob-event-based-source Receive data from Azure Service Bus subscribed to Azure Eventgrid reporting events related to a Azure Storage Blob account.
- Azure Storage Blob Sink kamelet:azure-storage-blob-sink Upload data to Azure Storage Blob.
- Azure Storage Blob Source kamelet:azure-storage-blob-source Consume files from Azure Storage Blob.
- Azure Storage Blob Data Lake Sink kamelet:azure-storage-datalake-sink Send data to Azure Storage Blob Data Lake.
- Azure Storage Blob Data Lake Source kamelet:azure-storage-datalake-source Consume files from Azure Storage Blob Data Lake.
- Azure Storage Files Sink kamelet:azure-storage-files-sink Upload data to Azure Storage Files Share.
- Azure Storage File Source kamelet:azure-storage-files-source Consume files from Azure Storage File Shares.
- Azure Storage Queue Sink kamelet:azure-storage-queue-sink Send events to Azure Storage queues.
- Azure Storage Queue Source kamelet:azure-storage-queue-source Receive events from Azure Storage queues.
- Bitcoin Source kamelet:bitcoin-source Provides a feed of the value of the Bitcoin compared to USDT using the Binance service.
- Caffeine Action kamelet:caffeine-action Perform operations on a caffeine cache.
- Cassandra Sink kamelet:cassandra-sink Send data to an Apache Cassandra cluster.
- Cassandra Source kamelet:cassandra-source Send a query to an Apache Cassandra cluster table.
- Ceph Sink kamelet:ceph-sink Upload data to a Ceph Bucket managed by an Object Storage Gateway.
- Ceph Source kamelet:ceph-source Receive data from a Ceph Bucket, managed by an Object Storage Gateway.
- Chuck Norris Source kamelet:chuck-norris-source Gets Chuck Norris jokes periodically.
- Chunk Template Action kamelet:chunk-template-action Apply a Chunk Template.
- Couchbase Sink kamelet:couchbase-sink Send documents to Couchbase.
- Counter Source kamelet:counter-source Generates sequential number events starting from a configurable value, incrementing by a specified step. Useful for testing, scheduled tasks, or creating ordered event sequences.
- Cron Source kamelet:cron-source Send events at specific time.
- Crypto Decrypt Action kamelet:crypto-decrypt-action Decrypt the payload using the Java Cryptographic Extension (JCE) and a fixed key.
- Crypto Encrypt Action kamelet:crypto-encrypt-action Encrypt the payload using the Java Cryptographic Extension (JCE) and a fixed key.
- Data Type Action kamelet:data-type-action Applies a given data type with respective data transformation.
- Databricks Sink kamelet:databricks-sink Send data to a Databricks Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters. For Unity Catalog workspaces, specify catalog and schema parameters.
- Databricks Source kamelet:databricks-source Query data from a Databricks Database. For Unity Catalog workspaces, specify catalog and schema parameters.
- Delay Action kamelet:delay-action Delay the processing using a specific amount of time.
- Image-to-Text Action kamelet:djl-image-to-text-action Detect and classify objects in an image into texts using the SSD and ResNet models and the ImageNet dataset.
- DNS DIG Action kamelet:dns-dig-action Query a DNS through Dig.
- DNS IP Action kamelet:dns-ip-action Get an IP from a DNS.
- DNS Lookup Action kamelet:dns-lookup-action Look up a domain.
- Drop Field Action kamelet:drop-field-action Removes a custom field by given name from the message in transit.
- Drop Header Action kamelet:drop-header-action Remove a header from the message in transit.
- Drop Headers Action kamelet:drop-headers-action Remove headers from the message in transit based on a pattern.
- Dropbox Sink kamelet:dropbox-sink Upload Files to Dropbox.
- Dropbox Source kamelet:dropbox-source Consume Files from Dropbox.
- Earthquake Source kamelet:earthquake-source Get data about current earthquake events happening in the world using the USGS API.
- ElasticSearch Index Sink kamelet:elasticsearch-index-sink Stores JSON-formatted data into ElasticSearch.
- ElasticSearch Search Source kamelet:elasticsearch-search-source Search data on ElasticSearch.
- Exec Sink kamelet:exec-sink Execute system commands.
- Extract Field Action kamelet:extract-field-action Extract a field from the message body.
- FHIR Sink kamelet:fhir-sink Forward data to a FHIR endpoint.
- FHIR Source kamelet:fhir-source Receive data from FHIR server.
- File Watch Source kamelet:file-watch-source Receive events related to a file or folder. It may require a volume mounting on Kubernetes.
- Freemarker Template Action kamelet:freemarker-template-action Apply a Freemarker Template.
- FTP Sink kamelet:ftp-sink Send data to an FTP server.
- FTP Source kamelet:ftp-source Receive data from an FTP server.
- FTPS Sink kamelet:ftps-sink Send data to an FTPS server.
- FTPS Source kamelet:ftps-source Receive data from an FTPS server.
- GitHub Commit Source kamelet:github-commit-source Receive commit From GitHub.
- GitHub Event Source kamelet:github-event-source Receive Events From a GitHub Repository.
- GitHub Pull Request Comments Source kamelet:github-pullrequest-comment-source Receive pull request Comments From GitHub.
- GitHub Pull Request Source kamelet:github-pullrequest-source Receive pull request From GitHub.
- GitHub Tag Source kamelet:github-tag-source Receive Tags From a GitHub Repository.
- Google Big Query Sink kamelet:google-bigquery-sink Send data to a Google Big Query table.
- Google Calendar Source kamelet:google-calendar-source Receive event data from Google Calendar.
- Google Functions Sink kamelet:google-functions-sink Send data to Google Functions.
- Google Mail Source kamelet:google-mail-source Receive data from Google Mail.
- Google Pubsub Sink kamelet:google-pubsub-sink Send messages to Google Cloud Pub/Sub.
- Google Pubsub Source kamelet:google-pubsub-source Consume messages from Google Cloud Pub/Sub.
- Google Sheets Sink kamelet:google-sheets-sink Send data to Google Sheets and update/append values on a spreadsheet.
- Google Sheets Source kamelet:google-sheets-source Receive data from Google Sheets.
- Google Storage Event-based Source kamelet:google-storage-event-based-source Receive data from Google Pubsub reporting events related to a Google Storage bucket.
- Google Storage Sink kamelet:google-storage-sink Upload objects to Google Cloud Storage.
- Google Storage Source kamelet:google-storage-source Consume objects from Google Cloud Storage.
- Google Vertex AI Sink kamelet:google-vertexai-sink Send data to Google Vertex AI for generating content with generative AI models.
- GraphQL Sink kamelet:graphql-sink Forward data to a GraphQL endpoint.
- Has Header Filter Action kamelet:has-header-filter-action Filter message based on the presence of one header.
- Header Matches Filter Action kamelet:header-matches-filter-action Filter based on header value compared to regex.
- Hoist Field Action kamelet:hoist-field-action Wrap data in a single field.
- Secured HTTP Sink kamelet:http-secured-sink Forwards an event to a secured HTTP endpoint. Supports Oauth and Basic authentication.
- HTTP Secured Source kamelet:http-secured-source Periodically fetches a secured HTTP resource and provides the content as output. Supports Oauth and Basic authentication.
- HTTP Sink kamelet:http-sink Forward data to an HTTP or HTTPS endpoint.
- HTTP Source kamelet:http-source Periodically fetches an HTTP resource and provides the content as output.
- IBM Cloud Object Storage Sink kamelet:ibm-cos-sink Upload data to an IBM Cloud Object Storage Bucket.
- IBM Cloud Object Storage Source kamelet:ibm-cos-source Receive data from an IBM Cloud Object Storage Bucket.
- IBM Watson Natural Language Understanding Sink kamelet:ibm-watson-language-sink Analyze text using IBM Watson Natural Language Understanding to extract sentiment, entities, keywords, concepts, categories, and emotions.
- Infinispan Sink kamelet:infinispan-sink Write object to an Infinispan cache.
- Infinispan Source kamelet:infinispan-source Get Events from an Infinispan cache.
- Insert Field Action kamelet:insert-field-action Adds a custom field with a simple language parsed value to the message in transit.
- Insert Header Action kamelet:insert-header-action Adds a header with a simple language parsed expression to the message in transit.
- Is Tombstone Filter Action kamelet:is-tombstone-filter-action Filter based on the presence of body or not.
- Jira Add Comment Sink kamelet:jira-add-comment-sink Add a new comment to an existing issue in Jira.
- Jira Add Issue Sink kamelet:jira-add-issue-sink Add a new issue to Jira.
- Jira oauth Source kamelet:jira-oauth-source Receive notifications about new issues from Jira through OAuth authentication.
- Jira Source kamelet:jira-source Receive notifications about new issues from Jira.
- Jira Transition Issue Sink kamelet:jira-transition-issue-sink Sets a new status (transition to) of an existing issue in Jira.
- Jira Update Issue Sink kamelet:jira-update-issue-sink Update fields of an existing issue in Jira.
- JMS - AMQP 1.0 Sink kamelet:jms-amqp-10-sink Send data to any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll).
- JMS - AMQP 1.0 Source kamelet:jms-amqp-10-source Consume data from any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll).
- JMS - Apache Artemis Sink kamelet:jms-apache-artemis-sink Send data to an Apache Artemis message broker by using JMS.
- JMS - Apache Artemis Source kamelet:jms-apache-artemis-source Receive data from an Apache Artemis message broker by using JMS.
- JMS - IBM MQ Sink kamelet:jms-ibm-mq-sink A Kamelet that can produce events to an IBM MQ message queue using JMS.
- JMS - IBM MQ Source kamelet:jms-ibm-mq-source A Kamelet that can read events from an IBM MQ message queue using JMS.
- JMS Pooled - Apache Artemis Sink kamelet:jms-pooled-apache-artemis-sink Send data to an Apache Artemis message broker by using JMS Pooled.
- JMS Pooled - Apache Artemis Source kamelet:jms-pooled-apache-artemis-source Receive data from an Apache Artemis message broker by using JMS Pooled Connection.
- Jolt Transformation Action kamelet:jolt-transformation-action Apply a Jolt Transformation.
- JSLT Action kamelet:jslt-action Apply a JSLT query or transformation on JSON.
- Json Deserialize Action kamelet:json-deserialize-action Deserialize payload to JSON.
- Json Patch Action kamelet:json-patch-action Apply a Json Patch Transformation.
- Json Schema Validator Action kamelet:json-schema-validator-action Apply a Json Schema Template to validate the payload against.
- Json Serialize Action kamelet:json-serialize-action Serialize payload to JSON.
- Jsonata Action kamelet:jsonata-action Apply a Jsonata Transformation.
- Kafka Not Secured with Apicurio Registry Sink kamelet:kafka-apicurio-registry-not-secured-sink Send data to Kafka topics on an insecure broker with Apicurio Registry.
- Kafka Not Secured with Apicurio Registry Source kamelet:kafka-apicurio-registry-not-secured-source Receive data from Kafka topics on an insecure broker combined with Apicurio Registry.
- Azure Kafka through Eventhubs with Azure Schema Registry Sink kamelet:kafka-azure-schema-registry-sink Send data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
- Azure Kafka through Eventhubs with Azure Schema Registry Source kamelet:kafka-azure-schema-registry-source Receive data from Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
- Kafka Batch Not Secured with Apicurio Registry Source kamelet: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.
- Kafka Batch with Apicurio Registry secured with Keycloak Source kamelet: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.
- Azure Kafka Batch through Eventhubs with Azure Schema Registry Source kamelet: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.
- Kafka Batch Manual Commit Action kamelet:kafka-batch-manual-commit-action Manually commit Kafka Batch Offset.
- Kafka Batch Source kamelet: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.
- Kafka Manual Commit Action kamelet:kafka-manual-commit-action Manually commit Kafka Offset.
- Kafka not secured with Apicurio Registry secured with Keycloak for JSON schema support Source kamelet: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.
- Kafka Not Secured with Apicurio Registry secured with Keycloak Sink kamelet:kafka-not-secured-apicurio-registry-sink Send data to Kafka topics on an insecure broker with Apicurio Registry secured with Keycloak.
- Kafka not secured with Apicurio Registry secured with Keycloak Source kamelet:kafka-not-secured-apicurio-registry-source Receive data from Kafka topics on an insecure broker combined with Apicurio Registry secured with Keycloak.
- Kafka Sink kamelet:kafka-sink Send data to Kafka topics.
- Kafka Source kamelet:kafka-source Receive data from Kafka topics.
- Kubernetes Namespaces Source kamelet:kubernetes-namespaces-source Consume Events from Kubernetes Namespaces.
- Kubernetes Nodes Source kamelet:kubernetes-nodes-source Consume Events from Kubernetes Nodes.
- Kubernetes Pods Source kamelet:kubernetes-pods-source Consume Events from Kubernetes Pods.
- Log Action kamelet:log-action Logs all data that flows between source and sink, useful for debugging purposes.
- Log Sink kamelet:log-sink A sink that logs all data that it receives, useful for debugging purposes.
- Mail IMAP Source kamelet:mail-imap-source Receive unread emails from an IMAP mail server, marking them as read once they are received.
- Mail Sink kamelet:mail-sink Send mails to given SMTP server.
- MariaDB Sink kamelet:mariadb-sink Send data to a MariaDB Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- MariaDB Source kamelet:mariadb-source Query data from a MariaDB Database.
- Mask Fields Action kamelet:mask-field-action Mask fields with a constant value in the message in transit.
- Message Timestamp Router Action kamelet:message-timestamp-router-action Update the topic field as a function of the original topic name and the record's timestamp field.
- Minio Sink kamelet:minio-sink Upload data to MinIO.
- Minio Source kamelet:minio-source Receive data from MinIO.
- MongoDB Changes Stream Source kamelet:mongodb-changes-stream-source Consume Changes from MongoDB Collection in streaming mode.
- MongoDB Sink kamelet:mongodb-sink Send data to MongoDB.
- MongoDB Source kamelet:mongodb-source Consume data from MongoDB.
- MQTT Sink kamelet:mqtt-sink Allows sending messages to any endpoint that supports the MQTT protocol, such as a message broker.
- MQTT Source kamelet:mqtt-source Allows receiving messages from any endpoint that supports the MQTT protocol, such as a message broker.
- MQTT v5 Sink kamelet:mqtt5-sink Allows sending messages to any endpoint that supports the MQTT v5 protocol, such as a message broker.
- MQTT 5 Source kamelet:mqtt5-source Allows receiving messages from any endpoint that supports the MQTT v5 protocol, such as a message broker.
- Microsoft Exchange IMAP OAuth2 Source kamelet:ms-exchange-online-imap-oauth-source Receive unread emails from an IMAP Microsoft Exchange mail server, marking them as read once they are received.
- Mustache Template Action kamelet:mustache-template-action Apply a Mustache Template.
- Mvel Template Action kamelet:mvel-template-action Apply a Mvel Template.
- MySQL Sink kamelet:mysql-sink Send data to a MySQL Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- MySQL Source kamelet:mysql-source Query data from a MySQL Database.
- NATS Sink kamelet:nats-sink Send data to NATS topics.
- NATS Source kamelet:nats-source Receive data from NATS topics.
- Nominatim GeoCode Action kamelet:nominatim-geocode-action Find locations on Earth by name and address.
- OGC Api Feature Get Item Action kamelet:ogcapi-features-action Returns the items of the collection provided of an OGC API Features server.
- OpenSearch Index Sink kamelet:opensearch-index-sink Stores JSON-formatted data into Opensearch.
- OpenSearch Search Source kamelet:opensearch-search-source Search data on OpenSearch.
- Oracle Database Sink kamelet:oracle-database-sink Send data to an Oracle Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- Oracle Database Source kamelet:oracle-database-source Query data from an Oracle Database.
- PDF Action kamelet:pdf-action Create a PDF.
- PostgreSQL Sink kamelet:postgresql-sink Send data to a PostgreSQL Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- PostgreSQL Source kamelet:postgresql-source Query data from a PostgreSQL Database.
- PQC Key Encapsulation/Decapsulation Action kamelet:pqc-kem-action Encapsulate or Decapsulate a secret Key with a Post-Quantum Cryptography Key Encapsulation Mechanism (PQC KEM) algorithm.
- PQC Signature Action kamelet:pqc-signature-action Sign or verify a payload with a Post-Quantum Cryptography (PQC) algorithm.
- Predicate Filter Action kamelet:predicate-filter-action 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.
- Protobuf Deserialize Action kamelet:protobuf-deserialize-action Deserialize payload to Protobuf.
- Protobuf Serialize Action kamelet:protobuf-serialize-action Serialize payload to Protobuf.
- Pulsar Sink kamelet:pulsar-sink Send documents to Pulsar.
- Pulsar Source kamelet:pulsar-source Receive data from Pulsar topics.
- Redis Sink kamelet:redis-sink Write object to a Redis cache.
- Redis Source kamelet:redis-source Get Events from a Redis cache.
- Regex Router Action kamelet:regex-router-action Update the destination using the configured regular expression and replacement string.
- Replace Field Action kamelet:replace-field-action Replace field with a different key in the message in transit.
- Resolve Schema Action kamelet:resolve-pojo-schema-action Resolves schema from given mime type and payload. Sets the resolved schema, the schema type and its content class as properties for later reference.
- REST OpenAPI Sink kamelet:rest-openapi-sink Load an OpenAPI specification from a URI and call an operation on an HTTP service. The request that is generated respects the rules given in the OpenAPI specification (for example, path parameters and Content-Type).
- Salesforce composite upsert Sink kamelet:salesforce-composite-upsert-sink Upsert Composite List of sObjects in Salesforce.
- Salesforce Create Sink kamelet:salesforce-create-sink Create an object in Salesforce.
- Salesforce Delete Sink kamelet:salesforce-delete-sink Remove an object from Salesforce.
- Salesforce Source kamelet:salesforce-source Receive updates from Salesforce.
- Salesforce Update Sink kamelet:salesforce-update-sink Update an object in Salesforce.
- SCP Sink kamelet:scp-sink Send file to an FTP Server through Secure Copy Protocol.
- Set Body Action kamelet:set-body-action Sets a simple language parsed value as the new message body in transit.
- Set Kafka Key Action kamelet:set-kafka-key-action Set Kafka Key based on a specific incoming header value from the message body.
- SFTP Sink kamelet:sftp-sink Send data to an SFTP Server.
- SFTP Source kamelet:sftp-source Receive data from an SFTP server.
- Simple Filter Action kamelet:simple-filter-action Filter based on simple expression.
- Slack Sink kamelet:slack-sink Send messages to a Slack channel.
- Slack Source kamelet:slack-source Receive messages from a Slack channel.
- Snowflake Sink kamelet:snowflake-sink Send data to a Snowflake Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- Snowflake Source kamelet:snowflake-source Query data from a Snowflake Database.
- Solr Sink kamelet:solr-sink Send documents to Solr Collection.
- Solr Source kamelet:solr-source Query for documents to Solr Collection.
- Splunk HEC Sink kamelet:splunk-hec-sink Send data to Splunk through its HTTP Event Collector.
- Splunk Sink kamelet:splunk-sink Send data to Splunk either by using "submit" or "stream" mode.
- Splunk Source kamelet:splunk-source Retrieve data from Splunk and outputs in json format.
- RabbitMQ Sink kamelet:spring-rabbitmq-sink Send data to a RabbitMQ Broker.
- RabbitMQ Source kamelet:spring-rabbitmq-source Receive data from a RabbitMQ Broker.
- Microsoft SQL Server Sink kamelet:sqlserver-sink Send data to a Microsoft SQL Server Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- Microsoft SQL Server Source kamelet:sqlserver-source Query data from a Microsoft SQL Server Database.
- SSH Sink kamelet:ssh-sink Send command through SSH session.
- SSH Source kamelet:ssh-source Receive data from SSH session.
- String Template Action kamelet:string-template-action Apply a String Template.
- Telegram Sink kamelet:telegram-sink Send a message to a Telegram chat by using your Telegram bot as sender.
- Telegram Source kamelet:telegram-source Receive all messages that people send to your Telegram bot.
- Throttle Action kamelet:throttle-action The Throttle action allows you to ensure that a specific sink does not get overloaded.
- Timer Source kamelet:timer-source Produces periodic messages with a custom payload.
- Timestamp Router Action kamelet:timestamp-router-action Update the topic field as a function of the original topic name and the record timestamp.
- Kafka Topic Name Matches Filter Action kamelet:topic-name-matches-filter-action Filter based on kafka topic value compared to regex.
- Twitter Direct Message Source kamelet:twitter-directmessage-source Gets all direct messages for your Twitter account.
- Twitter Search Source kamelet:twitter-search-source Gets all tweets on particular keywords from Twitter.
- Twitter Timeline Source kamelet:twitter-timeline-source Gets tweets from the timeline of a specific user from Twitter.
- Value to Key Action kamelet:value-to-key-action Replace the Kafka record key with a new key formed from a fields subset coming from the message body.
- Velocity Template Action kamelet:velocity-template-action Apply a Velocity Template.
- Webhook Source kamelet:webhook-source Creates an HTTP endpoint that can be used as a bridge to forward data to the Kamelet sink.
- wttr.in Source kamelet:wttrin-source Get weather forecasts from the wttr.in weather forecast service.
- XJ Identity Action kamelet:xj-identity-action Apply the XJ Identity Transformation to transform JSON to XML and XML to JSON.
- XJ Template Action kamelet:xj-template-action Apply the XJ Template Transformation to transform JSON to XML and XML to JSON.
Adding a connector
A component of the Camel catalog needs nothing: the build finds it in your routes and resolves its jars once in Weik.io. Other jars come from Maven coordinates in integration.yaml, or as jar files in the integration's folder, such as a libs/ folder for a driver that is in no repository.
An air-gapped installation resolves every jar through its own Maven mirror, so your own agents never reach the internet.
erp-invoice-export/integration.yaml
name: erp-invoice-export
version: 1.0.0
camelVersion: "4.22.1"
dependencies:
# a Camel component the routes don't reveal by URI
- camel:jdbc
- mvn:com.microsoft.sqlserver:mssql-jdbc:12.8.1.jre11Try Weik.io
The dev container runs the whole platform on your laptop with Camel 4.22.1, the version this page lists.