Connectors
Integrations in Weik.io use Camel's components and kamelets. This page lists the 388 components and 250 kamelets of Camel 4.22.1, the default Camel line of Weik.io 2026.2.
All connectors
638 shown
Components
- A2Aa2a:A2A endpoint for agent-to-agent communication.
- ActiveMQ 5.xactivemq:Send messages to (or consume from) Apache ActiveMQ 5.x. This component extends the Camel JMS component.
- ActiveMQ 6.xactivemq6:Send messages to (or consume from) Apache ActiveMQ 6.x. This component extends the Camel JMS component.
- AI Toolai-tool:Framework-agnostic consumer endpoint that registers a Camel route as an LLM tool in the shared AiToolRegistry.
- AMQPamqp:Messaging with AMQP protocol using Apache Qpid Client.
- ArangoDbarangodb:Perform operations on ArangoDb when used as a Document Database, or as a Graph Database.
- AS2as2:Transfer data securely and reliably using the AS2 protocol (RFC4130).
- Asteriskasterisk:Interact with Asterisk PBX Server (VoIP).
- Atmosphere Websocketatmosphere-websocket:Expose WebSocket endpoints using the Atmosphere framework.
- Atomatom:Poll Atom RSS feeds.
- Avro RPCavro:Produce or consume Apache Avro RPC services.
- AWS Bedrock Agent Runtimeaws-bedrock-agent-runtime:Invoke Model of AWS Bedrock Agent Runtime service.
- AWS Bedrock Agentaws-bedrock-agent:Operate on AWS Bedrock through its Agent.
- AWS Bedrockaws-bedrock:Invoke Model of AWS Bedrock service.
- AWS CloudTrailaws-cloudtrail:Consume events from Amazon CloudTrail using AWS SDK version 2.x.
- AWS Config Serviceaws-config:Manage AWS Config service.
- AWS Secrets Manageraws-secrets-manager:Manage secrets using AWS Secrets Manager.
- AWS Security Hubaws-security-hub:Manage and interact with AWS Security Hub for security findings.
- AWS Athenaaws2-athena:Access AWS Athena.
- AWS Comprehendaws2-comprehend:Perform natural language processing using AWS Comprehend and AWS SDK version 2.x.
- AWS CloudWatchaws2-cw:Sending metrics to AWS CloudWatch.
- AWS DynamoDBaws2-ddb:Store and retrieve data from AWS DynamoDB.
- AWS DynamoDB Streamsaws2-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 Eventbridgeaws2-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 Firehoseaws2-kinesis-firehose:Produce data to AWS Kinesis Firehose streams.
- AWS Kinesisaws2-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 Lambdaaws2-lambda:Manage and invoke AWS Lambda functions.
- AWS MQaws2-mq:Send messages to AWS MQ.
- AWS Managed Streaming for Apache Kafka (MSK)aws2-msk:Manage AWS MSK instances.
- AWS Pollyaws2-polly:Synthesize speech using AWS Polly and AWS SDK version 2.x.
- AWS RedshiftDataaws2-redshift-data:Perform operations on AWS Redshift using Redshift Data API.
- AWS Rekognitionaws2-rekognition:Manage and invoke AWS Rekognition.
- AWS S3 Vectorsaws2-s3-vectors:Store and query vector embeddings using AWS S3 Vectors with similarity search.
- AWS S3 Storage Serviceaws2-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 StepFunctionsaws2-step-functions:Manage and invoke AWS Step functions.
- AWS Security Token Service (STS)aws2-sts:Manage AWS STS cluster instances.
- AWS Textractaws2-textract:Extract text and data from documents using AWS Textract and AWS SDK version 2.x.
- AWS Timestreamaws2-timestream:Write records and execute queries on AWS time-series database.
- AWS Transcribeaws2-transcribe:Automatically convert speech to text using AWS Transcribe service.
- AWS Translateaws2-translate:Translate texts using AWS Translate and AWS SDK version 2.x.
- Azure CosmosDBazure-cosmosdb:To read and write records to the CosmosDB database on Azure cloud platform.
- Azure Event Hubsazure-eventhubs:Send and receive events to/from Azure Event Hubs using AMQP protocol.
- Azure Filesazure-files:Send and receive files to Azure storage file share.
- Azure Functionsazure-functions:Invoke and manage Azure Functions.
- Azure Key Vaultazure-key-vault:Manage secrets and keys in Azure Key Vault Service.
- Azure ServiceBusazure-servicebus:Send and receive messages to/from Azure Service Bus.
- Azure Storage Blob Serviceazure-storage-blob:Store and retrieve blobs from Azure Storage Blob Service.
- Azure Storage Data Lake Serviceazure-storage-datalake:Sends and receives files to/from Azure Data Lake Storage.
- Azure Storage Queue Serviceazure-storage-queue:Stores and retrieves messages to/from Azure Storage Queue.
- Bean Validatorbean-validator:Validate the message body using the Java Bean Validation API.
- Beanbean:Invoke methods of Java beans stored in Camel registry.
- Bonitabonita:Communicate with a remote Bonita BPM process engine.
- Boxbox:Upload, download and manage files, folders, groups, collaborations, etc. on box.com.
- Braintreebraintree:Process payments using Braintree Payments.
- Browsebrowse:Inspect the messages received on endpoints supporting BrowsableEndpoint.
- Caffeine Cachecaffeine-cache:Perform caching operations using Caffeine Cache.
- Caffeine LoadCachecaffeine-loadcache:Perform caching operations using Caffeine Cache with an attached CacheLoader.
- Camundacamunda:Interact with Camunda 8 Orchestration Clusters using the Camunda Java Client.
- ChatScriptchatscript:Chat with a ChatScript Server.
- Chunkchunk:Transform messages using Chunk templating engine.
- Classclass:Invoke methods of Java beans specified by class name.
- ClickHouseclickhouse:Interact with ClickHouse, the high-performance columnar OLAP database, for high-throughput ingestion and OLAP queries.
- ClickUpclickup:Receives events from ClickUp.
- CM SMS Gatewaycm-sms:Send SMS messages via CM SMS Gateway.
- CoAPcoap+tcp:Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CoAPcoap:Send and receive messages to/from CoAP (Constrained Application Protocol) capable devices.
- CoAPcoaps+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.
- CometDcometd: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.
- Consulconsul:Integrate with Consul service discovery and configuration store.
- Control Buscontrolbus:Manage and monitor Camel routes.
- Couchbasecouchbase:Query Couchbase databases using SQL (N1QL) queries or MapReduce Views with a poll strategy and/or perform various operations against Couchbase databases.
- CouchDBcouchdb: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 CQLcql:Integrate with Cassandra 2.0 using the CQL3 API (not the Thrift API). Based on Cassandra Java Driver provided by DataStax.
- Croncron: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).
- CXFcxf:Expose SOAP WebServices using Apache CXF or connect to external WebServices using CXF WS client.
- CXF-RScxfrs:Expose JAX-RS REST services using Apache CXF or connect to external REST services using CXF REST client.
- CyberArk Vaultcyberark-vault:Retrieve secrets from CyberArk Conjur Vault.
- Daprdapr:Dapr component which interfaces with Dapr Building Blocks.
- Data Formatdataformat:Use a Camel Data Format as a regular Camel Component.
- DataSet Testdataset-test:Extends the mock component by pulling messages from another endpoint on startup to set the expected message bodies.
- Datasetdataset:Provide data for load and soak testing of your Camel application.
- Debezium DB2 Connectordebezium-db2:Capture changes from a DB2 database.
- Debezium MongoDB Connectordebezium-mongodb:Capture changes from a MongoDB database.
- Debezium MySQL Connectordebezium-mysql:Capture changes from a MySQL database.
- Debezium Oracle Connectordebezium-oracle:Capture changes from an Oracle database.
- Debezium PostgreSQL Connectordebezium-postgres:Capture changes from a PostgreSQL database.
- Debezium SQL Server Connectordebezium-sqlserver:Capture changes from an SQL Server database.
- DFDLdfdl:Transforms fixed format data such as EDI message from/to XML using a Data Format Description Language (DFDL).
- DHIS2dhis2:Leverages the DHIS2 Java SDK to integrate Apache Camel with the DHIS2 Web API.
- Directdirect:Call another endpoint from the same Camel Context synchronously.
- Disruptor VMdisruptor-vm:Provides asynchronous SEDA behavior using LMAX Disruptor.
- Disruptordisruptor:Provides asynchronous SEDA behavior using LMAX Disruptor.
- Deep Java Librarydjl:Infer Deep Learning models from message exchanges data using Deep Java Library (DJL).
- DNSdns:Perform DNS queries using DNSJava.
- Dockerdocker:Manage Docker containers.
- Doclingdocling:Process documents using Docling library for parsing and conversion.
- Drilldrill:Perform queries against an Apache Drill cluster.
- Dropboxdropbox:Upload, download and manage files, folders, groups, collaborations, etc on Dropbox.
- DuckDBduckdb:Interact with DuckDB, the in-process analytical SQL database, for embedded analytics workloads.
- Dynamic Router Controldynamic-router-control:The Dynamic Router control endpoint for operations that allow routing participants to subscribe or unsubscribe to participate in dynamic message routing.
- Dynamic Routerdynamic-router:The Dynamic Router component routes exchanges to recipients, and the recipients (and their rules) may change at runtime.
- Ehcacheehcache:Perform caching operations using Ehcache.
- Elasticsearch Low level Rest Clientelasticsearch-rest-client:Perform queries and other operations on Elasticsearch or OpenSearch (uses low-level client).
- Elasticsearchelasticsearch:Send requests to Elasticsearch via Java Client API.
- Eventevent:Subscribe to Camel internal events such as route started/stopped and exchange completed/failed.
- Execexec:Execute commands on the underlying operating system.
- FHIRfhir:Exchange information in the healthcare domain using the FHIR (Fast Healthcare Interoperability Resources) standard.
- File Watchfile-watch:Get notified about file events in a directory using java.nio.file.WatchService.
- Filefile:Read and write files.
- Flatpackflatpack:Parse fixed width and delimited files using the FlatPack library.
- Flinkflink:Send DataSet jobs to an Apache Flink cluster.
- Flowableflowable:Send and receive messages from the Flowable BPMN and CMMN engines.
- FOPfop:Render messages into PDF and other output formats supported by Apache FOP.
- Freemarkerfreemarker:Transform messages using FreeMarker templates.
- FTPftp:Upload and download files to/from FTP servers.
- FTPSftps:Upload and download files to/from FTP servers supporting the FTPS protocol.
- Geocodergeocoder:Find geocodes (latitude and longitude) for a given address or the other way round.
- Gitgit:Perform operations on git repositories.
- GitHub2github2:Interact with the GitHub API.
- Google BigQuery Standard SQLgoogle-bigquery-sql:Access Google Cloud BigQuery service using SQL queries.
- Google BigQuerygoogle-bigquery:Google BigQuery data warehouse for analytics.
- Google Calendar Streamgoogle-calendar-stream:Poll for changes in a Google Calendar.
- Google Calendargoogle-calendar:Perform various operations on a Google Calendar.
- Google Drivegoogle-drive:Manage files in Google Drive.
- Google Firestoregoogle-firestore:Store and retrieve data from Google Cloud Firestore NoSQL database.
- Google Cloud Functionsgoogle-functions:Manage and invoke Google Cloud Functions.
- Google Mail Streamgoogle-mail-stream:Poll for incoming messages in Google Mail.
- Google Mailgoogle-mail:Manage messages in Google Mail.
- Google Pubsubgoogle-pubsub:Send and receive messages to/from Google Cloud Platform PubSub Service.
- Google Secret Managergoogle-secret-manager:Manage Google Secret Manager Secrets.
- Google Sheets Streamgoogle-sheets-stream:Poll for changes in Google Sheets.
- Google Sheetsgoogle-sheets:Manage spreadsheets in Google Sheets.
- Google Cloud Speech To Textgoogle-speech-to-text:Transcribe audio to text using Google Cloud Speech-to-Text API.
- Google Storagegoogle-storage:Store and retrieve objects from Google Cloud Storage Service using the google-cloud-storage library.
- Google Cloud Text To Speechgoogle-text-to-speech:Synthesize speech from text using the Google Cloud Text-to-Speech API.
- Google Vertex AIgoogle-vertexai:Interact with Google Cloud Vertex AI generative models.
- Google Cloud Visiongoogle-vision:Detect labels, text, faces, logos and more on images through Google Cloud Vision API.
- GraphQLgraphql:Send GraphQL queries and mutations to external systems.
- gRPCgrpc:Expose gRPC endpoints and access external gRPC endpoints.
- HashiCorp Vaulthashicorp-vault:Manage secrets in HashiCorp Vault Service.
- Hazelcast Instancehazelcast-instance:Consume join/leave events of a cache instance in a Hazelcast cluster.
- Hazelcast Listhazelcast-list:Perform operations on Hazelcast distributed list.
- Hazelcast Maphazelcast-map:Perform operations on Hazelcast distributed map.
- Hazelcast Multimaphazelcast-multimap:Perform operations on Hazelcast distributed multimap.
- Hazelcast PN Counterhazelcast-pncounter:Increment, decrement, get, etc. operations on a Hazelcast PN Counter (CRDT counter).
- Hazelcast Queuehazelcast-queue:Perform operations on Hazelcast distributed queue.
- Hazelcast Replicated Maphazelcast-replicatedmap:Perform operations on Hazelcast replicated map.
- Hazelcast Ringbufferhazelcast-ringbuffer:Perform operations on Hazelcast distributed ringbuffer.
- Hazelcast SEDAhazelcast-seda:Asynchronously send/receive Exchanges between Camel routes running on potentially distinct JVMs/hosts backed by Hazelcast BlockingQueue.
- Hazelcast Sethazelcast-set:Perform operations on Hazelcast distributed set.
- Hazelcast Topichazelcast-topic:Send and receive messages to/from Hazelcast distributed topic.
- HTTPhttp: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 Facehuggingface: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 FunctionGraphhwcloud-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 Recognitionhwcloud-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 Storageibm-cos:Store and retrieve objects from IBM Cloud Object Storage.
- IBM Secrets Manageribm-secrets-manager:Manage secrets in IBM Secrets Manager Service.
- IBM Watson Discoveryibm-watson-discovery:Perform document understanding and search using IBM Watson Discovery.
- IBM Watson Languageibm-watson-language:Perform natural language processing using IBM Watson Natural Language Understanding.
- IBM Watson Speech to Textibm-watson-speech-to-text:Convert speech audio to text using IBM Watson Speech to Text.
- IBM Watson Text to Speechibm-watson-text-to-speech:Convert text to natural-sounding speech using IBM Watson Text to Speech.
- IBM watsonx.aiibm-watsonx-ai:Interact with IBM watsonx.ai foundation models for text generation, chat, embeddings, and more.
- IBM watsonx.dataibm-watsonx-data:Interact with IBM watsonx.data lakehouse for catalog, schema, table, and engine management.
- Iggyiggy:Send and receive message to Apache Iggy streaming platform.
- Ignite Cacheignite-cache:Perform cache operations on an Ignite cache or consume changes from a continuous query.
- Ignite Computeignite-compute:Run compute operations on an Ignite cluster.
- Ignite Eventsignite-events:Receive events from an Ignite cluster by creating a local event listener.
- Ignite ID Generatorignite-idgen:Interact with Ignite Atomic Sequences and ID Generators .
- Ignite Messagingignite-messaging:Send and receive messages from an Ignite topic.
- Ignite Queuesignite-queue:Interact with Ignite Queue data structures.
- Ignite Setsignite-set:Interact with Ignite Set data structures.
- IMAPimap:Send and receive emails using imap, pop3 and smtp protocols.
- IMAPS (Secure)imaps:Send and receive emails using imap, pop3 and smtp protocols.
- Infinispan Embeddedinfinispan-embedded:Read and write from/to Infinispan distributed key/value store and data grid.
- Infinispaninfinispan:Read and write from/to Infinispan distributed key/value store and data grid.
- InfluxDBinfluxdb:Interact with InfluxDB v1, a time series database.
- InfluxDB2influxdb2:Interact with InfluxDB v2, a time series database.
- JCachejcache:Perform caching operations against JSR107/JCache.
- JCRjcr:Read and write nodes to/from a JCR compliant content repository.
- JDBCjdbc:Access databases through SQL and JDBC.
- Jettyjetty:Expose HTTP endpoints using Jetty 12.
- JGroups raftjgroups-raft:Exchange messages with JGroups-raft clusters.
- JGroupsjgroups:Exchange messages with JGroups clusters.
- Jirajira:Interact with JIRA issue tracker.
- JMSjms:Send and receive messages to/from JMS message brokers.
- JMXjmx:Receive JMX notifications.
- JOLTjolt:JSON to JSON transformation using JOLT.
- JOOQjooq:Store and retrieve Java objects from an SQL database using JOOQ.
- JPAjpa:Store and retrieve Java objects from databases using Java Persistence API (JPA).
- JSLTjslt:Query or transform JSON payloads using JSLT.
- JSON Schema Validatorjson-validator:Validate JSON payloads using NetworkNT JSON Schema.
- JSONatajsonata:Transforms JSON payload using JSONata transformation.
- JT400jt400: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.
- JTEjte:Transform messages using a Java based template engine (JTE).
- Kafkakafka:Send and receive messages to/from an Apache Kafka broker.
- Kameletkamelet:To call Kamelets.
- Keycloakkeycloak:Manage Keycloak instances via Admin API.
- Knativeknative:Send and receive events from Knative.
- KServekserve:Provide access to AI model servers with the KServe standard to run inference with remote models.
- Kubernetes ConfigMapkubernetes-config-maps:Perform operations on Kubernetes ConfigMaps and get notified on ConfigMaps changes.
- Kubernetes Cronjobkubernetes-cronjob:Perform operations on Kubernetes CronJob.
- Kubernetes Custom Resourceskubernetes-custom-resources:Perform operations on Kubernetes Custom Resources and get notified on Deployment changes.
- Kubernetes Deploymentskubernetes-deployments:Perform operations on Kubernetes Deployments and get notified on Deployment changes.
- Kubernetes Eventkubernetes-events:Perform operations on Kubernetes Events and get notified on Events changes.
- Kubernetes HPAkubernetes-hpa:Perform operations on Kubernetes Horizontal Pod Autoscalers (HPA) and get notified on HPA changes.
- Kubernetes Jobkubernetes-job:Perform operations on Kubernetes Jobs.
- Kubernetes Namespaceskubernetes-namespaces:Perform operations on Kubernetes Namespaces and get notified on Namespace changes.
- Kubernetes Nodeskubernetes-nodes:Perform operations on Kubernetes Nodes and get notified on Node changes.
- Kubernetes Persistent Volume Claimkubernetes-persistent-volumes-claims:Perform operations on Kubernetes Persistent Volumes Claims and get notified on Persistent Volumes Claim changes.
- Kubernetes Persistent Volumekubernetes-persistent-volumes:Perform operations on Kubernetes Persistent Volumes and get notified on Persistent Volume changes.
- Kubernetes Podskubernetes-pods:Perform operations on Kubernetes Pods and get notified on Pod changes.
- Kubernetes Replication Controllerkubernetes-replication-controllers:Perform operations on Kubernetes Replication Controllers and get notified on Replication Controllers changes.
- Kubernetes Resources Quotakubernetes-resources-quota:Perform operations on Kubernetes Resources Quotas.
- Kubernetes Secretskubernetes-secrets:Perform operations on Kubernetes Secrets.
- Kubernetes Service Accountkubernetes-service-accounts:Perform operations on Kubernetes Service Accounts.
- Kubernetes Serviceskubernetes-services:Perform operations on Kubernetes Services and get notified on Service changes.
- Kudukudu:Interact with Apache Kudu, a free and open source column-oriented data store of the Apache Hadoop ecosystem.
- LangChain4j Agentlangchain4j-agent:LangChain4j Agent component.
- LangChain4j Chatlangchain4j-chat:LangChain4j Chat component.
- LangChain4j Embeddingslangchain4j-embeddings:LangChain4j Embeddings.
- LangChain4j Embedding Storelangchain4j-embeddingstore:Perform operations on the LangChain4jEmbeddingStores.
- LangChain4j Web Searchlangchain4j-web-search:LangChain4j Web Search Engine.
- Languagelanguage:Execute scripts in any of the languages supported by Camel.
- LDAPldap:Perform searches on LDAP servers.
- LDIFldif:Perform updates on an LDAP server from an LDIF body content.
- Log Datalog:Prints data from the routed message (such as body and headers) to the logger.
- Printerlpr:Send print jobs to printers.
- Lucenelucene:Perform inserts or queries against Apache Lucene databases.
- Lumberjacklumberjack:Receive logs messages using the Lumberjack protocol.
- MapStructmapstruct:Type Conversion using MapStruct.
- Mastermaster:Have only a single consumer in a cluster consuming from a given endpoint. with automatic failover if the JVM dies.
- Metricsmetrics:Collect various metrics directly from Camel routes using the DropWizard metrics library.
- Micrometermicrometer:Collect various metrics directly from Camel routes using the Micrometer library.
- OPC UA Browsermilo-browse:Connect to OPC UA servers using the binary protocol for browsing the node tree.
- OPC UA Clientmilo-client:Connect to OPC UA servers using the binary protocol for acquiring telemetry data.
- OPC UA Servermilo-server:Make telemetry data available as an OPC UA server.
- Milvusmilvus:Perform operations on the Milvus Vector Database.
- MINA SFTPmina-sftp:Upload and download files to/from SFTP servers using Apache MINA SSHD.
- Minamina:Socket level networking using TCP or UDP with Apache Mina 2.x.
- Miniominio:Store and retrieve objects from Minio Storage Service using Minio SDK.
- MLLPmllp:Communicate with external systems using the MLLP protocol.
- Mockmock:Test routes and mediation rules using mocks.
- MongoDB GridFSmongodb-gridfs:Interact with MongoDB GridFS.
- MongoDBmongodb:Perform operations on MongoDB documents and collections.
- Mustachemustache:Transform messages using a Mustache template.
- MVELmvel:Transform messages using an MVEL template.
- MyBatis Beanmybatis-bean:Perform queries, inserts, updates or deletes in a relational database using MyBatis.
- MyBatismybatis:Performs a query, poll, insert, update or delete in a relational database using MyBatis.
- Natsnats:Send and receive messages from NATS messaging system.
- Neo4jneo4j:Perform operations on the Neo4j Graph Database.
- Netty HTTPnetty-http:Netty HTTP server and client using the Netty 4.x.
- Nettynetty:Socket level networking using TCP or UDP with Netty 4.x.
- OAI-PMHoaipmh:Harvest metadata using OAI-PMH protocol.
- Onceonce:Trigger a single message only once at startup (useful for development and testing purposes).
- OpenAIopenai:OpenAI endpoint for chat completion, Responses API, embeddings, audio transcription, audio translation, and text-to-speech.
- OpenSearchopensearch:Send requests to OpenSearch via Java Client API.
- OpenShift Build Configopenshift-build-configs:Perform operations on OpenShift Build Configs.
- OpenShift Buildsopenshift-builds:Perform operations on OpenShift Builds.
- OpenShift Deployment Configsopenshift-deploymentconfigs:Perform operations on OpenShift Deployment Configs and get notified on Deployment Config changes.
- OpenStack Cinderopenstack-cinder:Access data in OpenStack Cinder block storage.
- OpenStack Glanceopenstack-glance:Manage VM images and metadata definitions in OpenStack Glance.
- OpenStack Keystoneopenstack-keystone:Access OpenStack Keystone for API client authentication, service discovery and distributed multi-tenant authorization.
- OpenStack Neutronopenstack-neutron:Access OpenStack Neutron for network services.
- OpenStack Novaopenstack-nova:Access OpenStack to manage compute resources.
- OpenStack Swiftopenstack-swift:Access OpenStack Swift object/blob store.
- OpenTelemetry Metricsopentelemetry-metrics:Camel metrics based on the Camel Telemetry spec.
- OptaPlanneroptaplanner:Solve planning problems with OptaPlanner.
- Paho MQTT 5paho-mqtt5:Communicate with MQTT message brokers using Eclipse Paho MQTT v5 Client.
- PDFpdf:Create, modify or extract content from PDF documents.
- PostgreSQL Replication Slotpg-replication-slot:Poll for PostgreSQL Write-Ahead Log (WAL) records using Streaming Replication Slots.
- PostgreSQL Eventpgevent:Send and receive PostgreSQL events via LISTEN and NOTIFY commands.
- PGVectorpgvector:Perform operations on the PostgreSQL pgvector Vector Database.
- Pineconepinecone:Perform operations on the Pinecone Vector Database.
- Platform HTTPplatform-http:Expose HTTP endpoints using the HTTP server available in the current platform.
- PLC4Xplc4x:Read and write to PLC devices.
- POP3pop3:Send and receive emails using imap, pop3 and smtp protocols.
- POP3Spop3s:Send and receive emails using imap, pop3 and smtp protocols.
- PQC Algorithmspqc:Post Quantum Cryptography Signature and Verification component.
- PubNubpubnub:Send and receive messages to/from PubNub data stream network for connected devices.
- Pulsarpulsar:Send and receive messages from/to Apache Pulsar messaging system.
- Qdrantqdrant:Perform operations on the Qdrant Vector Database.
- Quartzquartz:Schedule sending of messages using the Quartz 2.x scheduler.
- QuickFixquickfix:Open a Financial Interchange (FIX) session using an embedded QuickFix/J engine.
- Reactive Streamsreactive-streams:Exchange messages with reactive stream processing libraries compatible with the reactive streams standard.
- Refref:Route messages to an endpoint looked up dynamically by name in the Camel Registry.
- REST APIrest-api:Expose OpenAPI Specification of the REST services defined using Camel REST DSL.
- REST OpenApirest-openapi:To call and expose REST services using OpenAPI specification as contract.
- RESTrest:Expose REST services or call external REST services.
- Robot Frameworkrobotframework:Pass camel exchanges to acceptance test written in Robot DSL.
- RocketMQrocketmq:Send and receive messages from RocketMQ cluster.
- RSSrss:Poll RSS feeds.
- Sagasaga:Execute custom actions within a route using the Saga EIP.
- Salesforcesalesforce:Communicate with Salesforce using Java DTOs.
- SAP NetWeaversap-netweaver:Send requests to SAP NetWeaver Gateway using HTTP.
- Schedulerscheduler:Generate messages in specified intervals using java.util.concurrent.ScheduledExecutorService.
- Schematronschematron:Validate XML payload using the Schematron Library.
- SCPscp:Copy files to/from remote hosts using the secure copy protocol (SCP).
- SEDAseda:Asynchronously call another endpoint from any Camel Context in the same JVM.
- ServiceNowservicenow:Interact with ServiceNow via its REST API.
- Servletservlet:Serve HTTP requests by a Servlet.
- SFTPsftp:Upload and download files to/from SFTP servers.
- Shellshell:Camel Shell component.
- Simple JMSsjms:Send and receive messages to/from a JMS Queue or Topic using plain JMS 1.x API.
- Simple JMS2sjms2:Send and receive messages to/from a JMS Queue or Topic using plain JMS 2.x API.
- Slackslack:Send and receive messages to/from Slack.
- SMBsmb:Read and write files to Server Message Block (SMB) file shares.
- Smookssmooks:Use Smooks to transform, route, and bind both XML and non-XML data, including EDI, CSV, JSON, and YAML.
- SMPPsmpp: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).
- SMTPsmtp:Send and receive emails using imap, pop3 and smtp protocols.
- SMTPSsmtps:Send and receive emails using imap, pop3 and smtp protocols.
- SNMPsnmp:Receive traps and poll SNMP (Simple Network Management Protocol) capable devices.
- Solrsolr:Perform operations against Apache Lucene Solr.
- Splunk HECsplunk-hec:The splunk component allows publishing events in Splunk using the HTTP Event Collector.
- Spring AI Chatspring-ai-chat:Perform chat operations using Spring AI.
- Spring AI Embeddingsspring-ai-embeddings:Spring AI Embeddings.
- Spring AI Imagespring-ai-image:Spring AI Image Generation.
- Spring AI Vector Storespring-ai-vector-store:Spring AI Vector Store.
- Spring Batchspring-batch:Send messages to Spring Batch for further processing.
- Spring Eventspring-event:Listen for Spring Application Events.
- Spring JDBCspring-jdbc:Access databases through SQL and JDBC with Spring Transaction support.
- Spring LDAPspring-ldap:Perform searches in LDAP servers using filters as the message payload.
- Spring RabbitMQspring-rabbitmq:Send and receive messages from RabbitMQ using the Spring RabbitMQ client.
- Spring Redisspring-redis:Send and receive messages from Redis.
- Spring WebServicespring-ws:Access external web services as a client or expose your own web services.
- SQL Stored Proceduresql-stored:Perform SQL queries as a JDBC Stored Procedures using Spring JDBC.
- SQLsql:Perform SQL queries using Spring JDBC.
- SSHssh:Execute commands on remote hosts using SSH.
- StAXstax:Process XML payloads by a SAX ContentHandler.
- Stitchstitch:Stitch is a cloud ETL service that integrates various data sources into a central data warehouse through various integrations.
- Streamstream:Read from system-in and write to system-out and system-err streams.
- String Templatestring-template:Transform messages using StringTemplate engine.
- Stripestripe:Interact with the Stripe payment platform.
- Stubstub:Stub out any physical endpoints while in development or testing.
- Tahu Edge Node / Devicetahu-edge:Sparkplug B Edge Node and Device support over MQTT using Eclipse Tahu.
- Tahu Host Applicationtahu-host:Sparkplug B Host Application support over MQTT using Eclipse Tahu.
- Telegramtelegram:Send and receive messages using the Telegram Bot API.
- TensorFlow Servingtensorflow-serving:Provide access to TensorFlow Serving model servers to run inference with TensorFlow saved models remotely.
- Thriftthrift:Call and expose remote procedures (RPC) with Apache Thrift data format and serialization mechanism.
- Thymeleafthymeleaf:Transform messages using a Thymeleaf template.
- Tikatika:Parse documents and extract metadata and text using Apache Tika.
- Timertimer:Generate messages in specified intervals using java.util.Timer.
- Twiliotwilio:Interact with Twilio REST APIs using Twilio Java SDK.
- Twitter Direct Messagetwitter-directmessage:Send and receive Twitter direct messages.
- Twitter Searchtwitter-search:Access Twitter Search.
- Twitter Timelinetwitter-timeline:Send tweets and receive tweets from user's timeline.
- Undertowundertow:Expose HTTP and WebSocket endpoints and access external HTTP/WebSocket servers.
- Validatorvalidator:Validate the payload using XML Schema and JAXP Validation.
- Velocityvelocity:Transform messages using a Velocity template.
- Vert.x HTTP Clientvertx-http:Send requests to external HTTP servers using Vert.x.
- Vert.x WebSocketvertx-websocket:Expose WebSocket endpoints and connect to remote WebSocket servers using Vert.x.
- Vert.xvertx:Send and receive messages to/from Vert.x Event Bus.
- Wasmwasm:Invoke Wasm functions.
- Weatherweather:Poll the weather information from Open Weather Map.
- weaviateweaviate:Perform operations on the Weaviate Vector Database.
- Web3j Ethereum Blockchainweb3j:Interact with Ethereum nodes using web3j client API.
- Webhookwebhook:Expose webhook endpoints to receive push notifications for other Camel components.
- WhatsAppwhatsapp:Send messages to WhatsApp.
- WordPresswordpress:Manage posts and users using the WordPress API.
- Workdayworkday:Detect and parse documents using Workday.
- XChangexchange:Access market data and trade on Bitcoin and Altcoin exchanges.
- XJxj:Transform JSON and XML message using a XSLT.
- XML Security Signxmlsecurity-sign:Sign XML payloads using the XML signature specification.
- XML Security Verifyxmlsecurity-verify:Verify XML payloads using the XML signature specification.
- XMPPxmpp:Send and receive messages to/from an XMPP chat server.
- XQueryxquery:Query and/or transform XML payloads using XQuery and Saxon.
- XSLT Saxonxslt-saxon:Transform XML payloads using an XSLT template using Saxon.
- XSLTxslt:Transforms XML payload using an XSLT template.
- Zendeskzendesk:Manage Zendesk tickets, users, organizations, etc.
- ZooKeeper Masterzookeeper-master:Have only a single consumer in a cluster consuming from a given endpoint. with automatic failover if the JVM dies.
- ZooKeeperzookeeper: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 Actionkamelet:avro-deserialize-actionDeserialize payload to Avro.
- Avro Serialize Actionkamelet:avro-serialize-actionSerialize payload to Avro.
- AWS Bedrock Agent Runtime Sinkkamelet:aws-bedrock-agent-runtime-sinkSend data for invoking a knowledge base from AWS Bedrock.
- AWS Bedrock Text Sinkkamelet:aws-bedrock-text-sinkSend data for invoking a text model of Amazon Bedrock.
- AWS Cloudtrail Sourcekamelet:aws-cloudtrail-sourceReceive data from an AWS Cloudtrail.
- AWS CloudWatch Metrics Sinkkamelet:aws-cloudwatch-sinkSend data to Amazon CloudWatch metrics.
- AWS Comprehend Sinkkamelet:aws-comprehend-sinkSend data to AWS Comprehend for natural language processing.
- AWS DynamoDB Sinkkamelet:aws-ddb-sinkSend data to Amazon DynamoDB. The sent data inserts, updates, or deletes an item on the specified AWS DynamoDB table.
- AWS DynamoDB Streams Sourcekamelet:aws-ddb-streams-sourceReceive events from Amazon DynamoDB Streams.
- AWS EC2 Sinkkamelet:aws-ec2-sinkCheck the status of EC2 instances.
- AWS Eventbridge Sinkkamelet:aws-eventbridge-sinkSend 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 Sinkkamelet:aws-kinesis-firehose-sinkSend message to an AWS Kinesis Firehose Stream.
- AWS Kinesis Sinkkamelet:aws-kinesis-sinkSend data to AWS Kinesis.
- AWS Kinesis Sourcekamelet:aws-kinesis-sourceReceive data from AWS Kinesis.
- AWS Lambda Sinkkamelet:aws-lambda-sinkSend a payload to an AWS Lambda function.
- AWS Polly Sinkkamelet:aws-polly-sinkSynthesize speech from text using AWS Polly.
- AWS Redshift Sinkkamelet:aws-redshift-sinkSend 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 Sourcekamelet:aws-redshift-sourceQuery data from an AWS Redshift Database.
- AWS S3 Event Based Sourcekamelet:aws-s3-event-based-sourceReceive data from AWS SQS subscribed to Eventbridge Bus reporting events related to an S3 bucket or multiple buckets.
- AWS S3 Sinkkamelet:aws-s3-sinkUpload data to an Amazon S3 Bucket.
- AWS S3 Sourcekamelet:aws-s3-sourceReceive data from an Amazon S3 Bucket.
- AWS S3 Streaming upload Sinkkamelet:aws-s3-streaming-upload-sinkUpload data to AWS S3 in streaming upload mode.
- AWS Secrets Manager Sinkkamelet:aws-secrets-manager-sinkCreate a secret in AWS Secrets Manager.
- AWS SES Sinkkamelet:aws-ses-sinkSend email through the Amazon Simple Email Service (SES).
- AWS SNS FIFO Sinkkamelet:aws-sns-fifo-sinkSend message to an AWS SNS FIFO Topic.
- AWS SNS Sinkkamelet:aws-sns-sinkSend message to an Amazon Simple Notification Service (SNS) topic.
- AWS SQS Batch Sinkkamelet:aws-sqs-batch-sinkSend Batch message to an AWS SQS Queue.
- AWS SQS FIFO Sinkkamelet:aws-sqs-fifo-sinkSend message to an AWS SQS FIFO Queue.
- AWS SQS Sinkkamelet:aws-sqs-sinkSend messages to an Amazon Simple Queue Service (SQS) queue.
- AWS SQS Sourcekamelet:aws-sqs-sourceReceive data from AWS SQS.
- AWS STS Assume Role Actionkamelet:aws-sts-assume-role-actionAssume a role through STS.
- AWS Timestream Query Sinkkamelet:aws-timestream-query-sinkQuery an AWS Timestream Database.
- AWS Translate Actionkamelet:aws-translate-actionTranslate a text in a specific language.
- Azure CosmosDB Sinkkamelet:azure-cosmosdb-sinkSend Data to an Azure CosmosDB instance.
- Azure CosmosDB Sourcekamelet:azure-cosmosdb-sourceConsume Changes from a CosmosDB instance.
- Azure Eventhubs Sinkkamelet:azure-eventhubs-sinkSend events to Azure Event Hubs.
- Azure Eventhubs Sourcekamelet:azure-eventhubs-sourceReceive events from Azure Event Hubs.
- Azure Function Sinkkamelet:azure-functions-sinkForward data to an Azure Function.
- Azure Servicebus Sinkkamelet:azure-servicebus-sinkSend Messages to Azure Servicebus.
- Azure Servicebus Sourcekamelet:azure-servicebus-sourceConsume Messages from Azure Servicebus.
- Azure Storage Blob Append Sinkkamelet:azure-storage-blob-append-sinkUpload data in append mode to Azure Storage Blob.
- Azure Storage Blob Changefeed Sourcekamelet:azure-storage-blob-changefeed-sourceConsume events from an Azure Storage Blob change feed.
- Azure Storage Blob Event-based Sourcekamelet:azure-storage-blob-event-based-sourceReceive data from Azure Service Bus subscribed to Azure Eventgrid reporting events related to a Azure Storage Blob account.
- Azure Storage Blob Sinkkamelet:azure-storage-blob-sinkUpload data to Azure Storage Blob.
- Azure Storage Blob Sourcekamelet:azure-storage-blob-sourceConsume files from Azure Storage Blob.
- Azure Storage Blob Data Lake Sinkkamelet:azure-storage-datalake-sinkSend data to Azure Storage Blob Data Lake.
- Azure Storage Blob Data Lake Sourcekamelet:azure-storage-datalake-sourceConsume files from Azure Storage Blob Data Lake.
- Azure Storage Files Sinkkamelet:azure-storage-files-sinkUpload data to Azure Storage Files Share.
- Azure Storage File Sourcekamelet:azure-storage-files-sourceConsume files from Azure Storage File Shares.
- Azure Storage Queue Sinkkamelet:azure-storage-queue-sinkSend events to Azure Storage queues.
- Azure Storage Queue Sourcekamelet:azure-storage-queue-sourceReceive events from Azure Storage queues.
- Bitcoin Sourcekamelet:bitcoin-sourceProvides a feed of the value of the Bitcoin compared to USDT using the Binance service.
- Caffeine Actionkamelet:caffeine-actionPerform operations on a caffeine cache.
- Cassandra Sinkkamelet:cassandra-sinkSend data to an Apache Cassandra cluster.
- Cassandra Sourcekamelet:cassandra-sourceSend a query to an Apache Cassandra cluster table.
- Ceph Sinkkamelet:ceph-sinkUpload data to an Ceph Bucket managed by a Object Storage Gateway.
- Ceph Sourcekamelet:ceph-sourceReceive data from an Ceph Bucket, managed by a Object Storage Gateway.
- Chuck Norris Sourcekamelet:chuck-norris-sourceGets periodically Chuck Norris jokes.
- Chunk Template Actionkamelet:chunk-template-actionApply a Chunk Template.
- Couchbase Sinkkamelet:couchbase-sinkSend documents to Couchbase.
- Counter Sourcekamelet:counter-sourceGenerates sequential number events starting from a configurable value, incrementing by a specified step. Useful for testing, scheduled tasks, or creating ordered event sequences.
- Cron Sourcekamelet:cron-sourceSend events at specific time.
- Crypto Decrypt Actionkamelet:crypto-decrypt-actionDecrypt the payload using the Java Cryptographic Extension (JCE) and a fixed key.
- Crypto Encrypt Actionkamelet:crypto-encrypt-actionEncrypt the payload using the Java Cryptographic Extension (JCE) and a fixed key.
- Data Type Actionkamelet:data-type-actionApplies a given data type with respective data transformation.
- Databricks Sinkkamelet:databricks-sinkSend 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 Sourcekamelet:databricks-sourceQuery data from a Databricks Database. For Unity Catalog workspaces, specify catalog and schema parameters.
- Delay Actionkamelet:delay-actionDelay the processing using a specific amount of time.
- Image-to-Text Actionkamelet:djl-image-to-text-actionDetect and classify objects in an image into texts using the SSD and ResNet models and the ImageNet dataset.
- DNS DIG Actionkamelet:dns-dig-actionQuery a DNS through Dig.
- DNS IP Actionkamelet:dns-ip-actionGet an IP from a DNS.
- DNS Lookup Actionkamelet:dns-lookup-actionLookup for a domain.
- Drop Field Actionkamelet:drop-field-actionRemoves a custom field by given name from the message in transit.
- Drop Header Actionkamelet:drop-header-actionRemove an header from the message in transit.
- Drop Headers Actionkamelet:drop-headers-actionRemove headers from the message in transit based on a pattern.
- Dropbox Sinkkamelet:dropbox-sinkUpload Files to Dropbox.
- Dropbox Sourcekamelet:dropbox-sourceConsume Files from Dropbox.
- Earthquake Sourcekamelet:earthquake-sourceGet data about current earthquake events happening in the world using the USGS API.
- ElasticSearch Index Sinkkamelet:elasticsearch-index-sinkStores JSON-formatted data into ElasticSearch.
- ElasticSearch Search Sourcekamelet:elasticsearch-search-sourceSearch data on ElasticSearch.
- Exec Sinkkamelet:exec-sinkExecute system commands.
- Extract Field Actionkamelet:extract-field-actionExtract a field from the message body.
- FHIR Sinkkamelet:fhir-sinkForward data to a FHIR endpoint.
- FHIR Sourcekamelet:fhir-sourceReceive data from FHIR server.
- File Watch Sourcekamelet:file-watch-sourceReceive events related to a file or folder. It may require a volume mounting on Kubernetes.
- Freemarker Template Actionkamelet:freemarker-template-actionApply a Freemarker Template.
- FTP Sinkkamelet:ftp-sinkSend data to an FTP server.
- FTP Sourcekamelet:ftp-sourceReceive data from an FTP server.
- FTPS Sinkkamelet:ftps-sinkSend data to an FTPS server.
- FTPS Sourcekamelet:ftps-sourceReceive data from an FTPS server.
- GitHub Commit Sourcekamelet:github-commit-sourceReceive commit From GitHub.
- GitHub Event Sourcekamelet:github-event-sourceReceive Events From a GitHub Repository.
- GitHub Pull Request Comments Sourcekamelet:github-pullrequest-comment-sourceReceive pull request Comments From GitHub.
- GitHub Pull Request Sourcekamelet:github-pullrequest-sourceReceive pull request From GitHub.
- GitHub Tag Sourcekamelet:github-tag-sourceReceive Tags From a GitHub Repository.
- Google Big Query Sinkkamelet:google-bigquery-sinkSend data to a Google Big Query table.
- Google Calendar Sourcekamelet:google-calendar-sourceReceive event data from Google Calendar.
- Google Functions Sinkkamelet:google-functions-sinkSend data to Google Functions.
- Google Mail Sourcekamelet:google-mail-sourceReceive data from Google Mail.
- Google Pubsub Sinkkamelet:google-pubsub-sinkSend messages to Google Cloud Pub/Sub.
- Google Pubsub Sourcekamelet:google-pubsub-sourceConsume messages from Google Cloud Pub/Sub.
- Google Sheets Sinkkamelet:google-sheets-sinkSend data to Google Sheets and update/append values on a spreadsheet.
- Google Sheets Sourcekamelet:google-sheets-sourceReceive data from Google Sheets.
- Google Storage Event-based Sourcekamelet:google-storage-event-based-sourceReceive data from Google Pubsub reporting events related to a Google Storage bucket.
- Google Storage Sinkkamelet:google-storage-sinkUpload objects to Google Cloud Storage.
- Google Storage Sourcekamelet:google-storage-sourceConsume objects from Google Cloud Storage.
- Google Vertex AI Sinkkamelet:google-vertexai-sinkSend data to Google Vertex AI for generating content with generative AI models.
- GraphQL Sinkkamelet:graphql-sinkForward data to a GraphQL endpoint.
- Has Header Filter Actionkamelet:has-header-filter-actionFilter message based on the presence of one header.
- Header Matches Filter Actionkamelet:header-matches-filter-actionFilter based on header value compared to regex.
- Hoist Field Actionkamelet:hoist-field-actionWrap data in a single field.
- Secured HTTP Sinkkamelet:http-secured-sinkForwards an event to a secured HTTP endpoint. Supports Oauth and Basic authentication.
- HTTP Secured Sourcekamelet:http-secured-sourcePeriodically fetches a secured HTTP resource and provides the content as output. Supports Oauth and Basic authentication.
- HTTP Sinkkamelet:http-sinkForward data to a HTTP or HTTPS endpoint.
- HTTP Sourcekamelet:http-sourcePeriodically fetches an HTTP resource and provides the content as output.
- IBM Cloud Object Storage Sinkkamelet:ibm-cos-sinkUpload data to an IBM Cloud Object Storage Bucket.
- IBM Cloud Object Storage Sourcekamelet:ibm-cos-sourceReceive data from an IBM Cloud Object Storage Bucket.
- IBM Watson Natural Language Understanding Sinkkamelet:ibm-watson-language-sinkAnalyze text using IBM Watson Natural Language Understanding to extract sentiment, entities, keywords, concepts, categories, and emotions.
- Infinispan Sinkkamelet:infinispan-sinkWrite object to an Infinispan cache.
- Infinispan Sourcekamelet:infinispan-sourceGet Events from an Infinispan cache.
- Insert Field Actionkamelet:insert-field-actionAdds a custom field with a simple language parsed value to the message in transit.
- Insert Header Actionkamelet:insert-header-actionAdds an header with a simple language parsed expression to the message in transit.
- Is Tombstone Filter Actionkamelet:is-tombstone-filter-actionFilter based on the presence of body or not.
- Jira Add Comment Sinkkamelet:jira-add-comment-sinkAdd a new comment to an existing issue in Jira.
- Jira Add Issue Sinkkamelet:jira-add-issue-sinkAdd a new issue to Jira.
- Jira oauth Sourcekamelet:jira-oauth-sourceReceive notifications about new issues from Jira through OAuth authentication.
- Jira Sourcekamelet:jira-sourceReceive notifications about new issues from Jira.
- Jira Transition Issue Sinkkamelet:jira-transition-issue-sinkSets a new status (transition to) of an existing issue in Jira.
- Jira Update Issue Sinkkamelet:jira-update-issue-sinkUpdate fields of an existing issue in Jira.
- JMS - AMQP 1.0 Sinkkamelet:jms-amqp-10-sinkSend 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 Sourcekamelet:jms-amqp-10-sourceConsume 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 Sinkkamelet:jms-apache-artemis-sinkSend data to an Apache Artemis message broker by using JMS.
- JMS - Apache Artemis Sourcekamelet:jms-apache-artemis-sourceReceive data from an Apache Artemis message broker by using JMS.
- JMS - IBM MQ Sinkkamelet:jms-ibm-mq-sinkA Kamelet that can produce events to an IBM MQ message queue using JMS.
- JMS - IBM MQ Sourcekamelet:jms-ibm-mq-sourceA Kamelet that can read events from an IBM MQ message queue using JMS.
- JMS Pooled - Apache Artemis Sinkkamelet:jms-pooled-apache-artemis-sinkSend data to an Apache Artemis message broker by using JMS Pooled.
- JMS Pooled - Apache Artemis Sourcekamelet:jms-pooled-apache-artemis-sourceReceive data from an Apache Artemis message broker by using JMS Pooled Connection.
- Jolt Transformation Actionkamelet:jolt-transformation-actionApply a Jolt Transformation.
- JSLT Actionkamelet:jslt-actionApply a JSLT query or transformation on JSON.
- Json Deserialize Actionkamelet:json-deserialize-actionDeserialize payload to JSON.
- Json Patch Actionkamelet:json-patch-actionApply a Json Patch Transformation.
- Json Schema Validator Actionkamelet:json-schema-validator-actionApply a Json Schema Template to validate the payload against.
- Json Serialize Actionkamelet:json-serialize-actionSerialize payload to JSON.
- Jsonata Actionkamelet:jsonata-actionApply a Jsonata Transformation.
- Kafka Not Secured with Apicurio Registry Sinkkamelet:kafka-apicurio-registry-not-secured-sinkSend data to Kafka topics on an insecure broker with Apicurio Registry.
- Kafka Not Secured with Apicurio Registry Sourcekamelet:kafka-apicurio-registry-not-secured-sourceReceive data from Kafka topics on an insecure broker combined with Apicurio Registry.
- Azure Kafka through Eventhubs with Azure Schema Registry Sinkkamelet:kafka-azure-schema-registry-sinkSend data to Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
- Azure Kafka through Eventhubs with Azure Schema Registry Sourcekamelet:kafka-azure-schema-registry-sourceReceive data from Kafka topics on Azure Eventhubs combined with Azure Schema Registry.
- Kafka Batch Not Secured with Apicurio Registry Sourcekamelet:kafka-batch-apicurio-registry-not-secured-sourceReceive 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 Sourcekamelet:kafka-batch-apicurio-registry-sourceReceive 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 Sourcekamelet:kafka-batch-azure-schema-registry-sourceReceive 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 Actionkamelet:kafka-batch-manual-commit-actionManually commit Kafka Batch Offset.
- Kafka Batch Sourcekamelet:kafka-batch-sourceReceive 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 Actionkamelet:kafka-manual-commit-actionManually commit Kafka Offset.
- Kafka not secured with Apicurio Registry secured with Keycloak for JSON schema support Sourcekamelet:kafka-not-secured-apicurio-registry-json-sourceReceive 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 Sinkkamelet:kafka-not-secured-apicurio-registry-sinkSend data to Kafka topics on an insecure broker with Apicurio Registry secured with Keycloak.
- Kafka not secured with Apicurio Registry secured with Keycloak Sourcekamelet:kafka-not-secured-apicurio-registry-sourceReceive data from Kafka topics on an insecure broker combined with Apicurio Registry secured with Keycloak.
- Kafka Sinkkamelet:kafka-sinkSend data to Kafka topics.
- Kafka Sourcekamelet:kafka-sourceReceive data from Kafka topics.
- Kubernetes Namespaces Sourcekamelet:kubernetes-namespaces-sourceConsume Events from Kubernetes Namespaces.
- Kubernetes Nodes Sourcekamelet:kubernetes-nodes-sourceConsume Events from Kubernetes Nodes.
- Kubernetes Pods Sourcekamelet:kubernetes-pods-sourceConsume Events from Kubernetes Pods.
- Log Actionkamelet:log-actionLogs all data that flows between source and sink, useful for debugging purposes.
- Log Sinkkamelet:log-sinkA sink that logs all data that it receives, useful for debugging purposes.
- Mail IMAP Sourcekamelet:mail-imap-sourceReceive unread emails from an IMAP mail server, marking them as read once they are received.
- Mail Sinkkamelet:mail-sinkSend mails to given SMTP server.
- MariaDB Sinkkamelet:mariadb-sinkSend data to a MariaDB Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- MariaDB Sourcekamelet:mariadb-sourceQuery data from a MariaDB Database.
- Mask Fields Actionkamelet:mask-field-actionMask fields with a constant value in the message in transit.
- Message Timestamp Router Actionkamelet:message-timestamp-router-actionUpdate the topic field as a function of the original topic name and the record's timestamp field.
- Minio Sinkkamelet:minio-sinkUpload data to MinIO.
- Minio Sourcekamelet:minio-sourceReceive data from MinIO.
- MongoDB Changes Stream Sourcekamelet:mongodb-changes-stream-sourceConsume Changes from MongoDB Collection in streaming mode.
- MongoDB Sinkkamelet:mongodb-sinkSend data to MongoDB.
- MongoDB Sourcekamelet:mongodb-sourceConsume data from MongoDB.
- MQTT Sinkkamelet:mqtt-sinkAllows sending messages to any endpoint that supports the MQTT protocol, such as a message broker.
- MQTT Sourcekamelet:mqtt-sourceAllows receiving messages from any endpoint that supports the MQTT protocol, such as a message broker.
- MQTT v5 Sinkkamelet:mqtt5-sinkAllows sending messages to any endpoint that supports the MQTT v5 protocol, such as a message broker.
- MQTT 5 Sourcekamelet:mqtt5-sourceAllows receiving messages from any endpoint that supports the MQTT v5 protocol, such as a message broker.
- Microsoft Exchange IMAP OAuth2 Sourcekamelet:ms-exchange-online-imap-oauth-sourceReceive unread emails from an IMAP Microsoft Exchange mail server, marking them as read once they are received.
- Mustache Template Actionkamelet:mustache-template-actionApply a Mustache Template.
- Mvel Template Actionkamelet:mvel-template-actionApply a Mvel Template.
- MySQL Sinkkamelet:mysql-sinkSend data to a MySQL Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- MySQL Sourcekamelet:mysql-sourceQuery data from a MySQL Database.
- NATS Sinkkamelet:nats-sinkSend data to NATS topics.
- NATS Sourcekamelet:nats-sourceReceive data from NATS topics.
- Nominatim GeoCode Actionkamelet:nominatim-geocode-actionFind locations on Earth by name and address.
- OGC Api Feature Get Item Actionkamelet:ogcapi-features-actionReturns the items of the collection provided of an OGC API Features server.
- OpenSearch Index Sinkkamelet:opensearch-index-sinkStores JSON-formatted data into Opensearch.
- OpenSearch Search Sourcekamelet:opensearch-search-sourceSearch data on OpenSearch.
- Oracle Database Sinkkamelet:oracle-database-sinkSend 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 Sourcekamelet:oracle-database-sourceQuery data from an Oracle Database.
- PDF Actionkamelet:pdf-actionCreate a PDF.
- PostgreSQL Sinkkamelet:postgresql-sinkSend data to a PostgreSQL Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- PostgreSQL Sourcekamelet:postgresql-sourceQuery data from a PostgreSQL Database.
- PQC Key Encapsulation/Decapsulation Actionkamelet:pqc-kem-actionEncapsulate or Decapsulate a secret Key with a Post-Quantum Cryptography Key Encapsulation Mechanism (PQC KEM) algorithm.
- PQC Signature Actionkamelet:pqc-signature-actionSign or verify a payload with a Post-Quantum Cryptography (PQC) algorithm.
- Predicate Filter Actionkamelet:predicate-filter-actionFilter 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 Actionkamelet:protobuf-deserialize-actionDeserialize payload to Protobuf.
- Protobuf Serialize Actionkamelet:protobuf-serialize-actionSerialize payload to Protobuf.
- Pulsar Sinkkamelet:pulsar-sinkSend documents to Pulsar.
- Pulsar Sourcekamelet:pulsar-sourceReceive data from Pulsar topics.
- Redis Sinkkamelet:redis-sinkWrite object to a Redis cache.
- Redis Sourcekamelet:redis-sourceGet Events from a Redis cache.
- Regex Router Actionkamelet:regex-router-actionUpdate the destination using the configured regular expression and replacement string.
- Replace Field Actionkamelet:replace-field-actionReplace field with a different key in the message in transit.
- Resolve Schema Actionkamelet:resolve-pojo-schema-actionResolves 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 Sinkkamelet:rest-openapi-sinkLoad an OpenAPI specification from a URI and call an operation on a 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 Sinkkamelet:salesforce-composite-upsert-sinkUpsert Composite List of sObjects in Salesforce.
- Salesforce Create Sinkkamelet:salesforce-create-sinkCreate an object in Salesforce.
- Salesforce Delete Sinkkamelet:salesforce-delete-sinkRemove an object from Salesforce.
- Salesforce Sourcekamelet:salesforce-sourceReceive updates from Salesforce.
- Salesforce Update Sinkkamelet:salesforce-update-sinkUpdate an object in Salesforce.
- SCP Sinkkamelet:scp-sinkSend file to an FTP Server through Secure Copy Protocol.
- Set Body Actionkamelet:set-body-actionSets a simple language parsed value as the new message body in transit.
- Set Kafka Key Actionkamelet:set-kafka-key-actionSet Kafka Key based on a specific incoming header value from the message body.
- SFTP Sinkkamelet:sftp-sinkSend data to an SFTP Server.
- SFTP Sourcekamelet:sftp-sourceReceive data from an SFTP server.
- Simple Filter Actionkamelet:simple-filter-actionFilter based on simple expression.
- Slack Sinkkamelet:slack-sinkSend messages to a Slack channel.
- Slack Sourcekamelet:slack-sourceReceive messages from a Slack channel.
- Snowflake Sinkkamelet:snowflake-sinkSend data to a Snowflake Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
- Snowflake Sourcekamelet:snowflake-sourceQuery data from a Snowflake Database.
- Solr Sinkkamelet:solr-sinkSend documents to Solr Collection.
- Solr Sourcekamelet:solr-sourceQuery for documents to Solr Collection.
- Splunk HEC Sinkkamelet:splunk-hec-sinkThe Splunk HEC sink allows to send data to Splunk using the https://docs.splunk.com/Documentation/Splunk/latest/Data/UsetheHTTPEventCollector[HTTP Event Collector].
- Splunk Sinkkamelet:splunk-sinkSend data to Splunk either by using "submit" or "stream" mode.
- Splunk Sourcekamelet:splunk-sourceRetrieve data from Splunk and outputs in json format.
- RabbitMQ Sinkkamelet:spring-rabbitmq-sinkSend data to a RabbitMQ Broker.
- RabbitMQ Sourcekamelet:spring-rabbitmq-sourceReceive data from a RabbitMQ Broker.
- Microsoft SQL Server Sinkkamelet:sqlserver-sinkSend 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 Sourcekamelet:sqlserver-sourceQuery data from a Microsoft SQL Server Database.
- SSH Sinkkamelet:ssh-sinkSend command through SSH session.
- SSH Sourcekamelet:ssh-sourceReceive data from SSH session.
- String Template Actionkamelet:string-template-actionApply a String Template.
- Telegram Sinkkamelet:telegram-sinkSend a message to a Telegram chat by using your Telegram bot as sender.
- Telegram Sourcekamelet:telegram-sourceReceive all messages that people send to your Telegram bot.
- Throttle Actionkamelet:throttle-actionThe Throttle action allows you to ensure that a specific sink does not get overloaded.
- Timer Sourcekamelet:timer-sourceProduces periodic messages with a custom payload.
- Timestamp Router Actionkamelet:timestamp-router-actionUpdate the topic field as a function of the original topic name and the record timestamp.
- Kafka Topic Name Matches Filter Actionkamelet:topic-name-matches-filter-actionFilter based on kafka topic value compared to regex.
- Twitter Direct Message Sourcekamelet:twitter-directmessage-sourceAllows to get all direct messages for your Twitter account.
- Twitter Search Sourcekamelet:twitter-search-sourceAllows to get all tweets on particular keywords from Twitter.
- Twitter Timeline Sourcekamelet:twitter-timeline-sourceAllows to get tweets from the timeline of a specific user from Twitter.
- Value to Key Actionkamelet:value-to-key-actionReplace the Kafka record key with a new key formed from a fields subset coming from the message body.
- Velocity Template Actionkamelet:velocity-template-actionApply a Velocity Template.
- Webhook Sourcekamelet:webhook-sourceCreates an HTTP endpoint that can be used as a bridge to forward data to the Kamelet sink.
- wttr.in Sourcekamelet:wttrin-sourceGet weather forecasts from the wttr.in weather forecast service.
- XJ Identity Actionkamelet:xj-identity-actionApply the XJ Identity Transformation to transform JSON to XML and XML to JSON.
- XJ Template Actionkamelet:xj-template-actionApply the XJ Template Transformation to transform JSON to XML and XML to JSON.
No connector matches. Camel can still reach the system through a jar from Maven, as the next section shows.
Adding a connector
A component of the Camel catalog needs nothing: the build finds it in your routes and resolves its jars once at the hub. 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 hub resolves every jar through its own Maven mirror, so the agents at your sites never reach the internet.
# erp-invoice-export/integration.yaml
name: erp-invoice-export
version: 1.0.0
camelVersion: "4.22.1"
dependencies:
- camel:jdbc # a Camel component the routes don't reveal by URI
- mvn:com.microsoft.sqlserver:mssql-jdbc:12.8.1.jre11Try Weik.io
A component of the catalog works in your first integration in the dev container, with no step to add it.