Apache Camel
Docs Tooling Security Community Blog
Download

Camel Kafka Connector

    • User guide
      • Getting started
        • Try it locally
        • Try it on Kubernetes
        • Try it on OpenShift cluster
        • Packages documentation
      • Basic concepts
      • Basic configuration
      • Aggregation
      • Idempotency
      • Remove Headers
      • Extending a Connector
        • Extensible connector archetype
        • Extensible Dataformat connector archetype
        • Extensible Apicurio connector archetype
    • Security Model
    • Contributor guide
      • Testing
      • Troubleshooting
      • Release Guide
    • Reference
      • Single Message Transformers (SMT)
        • Fields To Headers
      • Connectors
        • camel-aws-bedrock-agent-runtime-sink-kafka-connector
          • Sink Docs
        • camel-aws-bedrock-text-sink-kafka-connector
          • Sink Docs
        • camel-aws-cloudtrail-source-kafka-connector
          • Source Docs
        • camel-aws-cloudwatch-sink-kafka-connector
          • Sink Docs
        • camel-aws-comprehend-sink-kafka-connector
          • Sink Docs
        • camel-aws-ddb-sink-kafka-connector
          • Sink Docs
        • camel-aws-ddb-streams-source-kafka-connector
          • Source Docs
        • camel-aws-ec2-sink-kafka-connector
          • Sink Docs
        • camel-aws-eventbridge-sink-kafka-connector
          • Sink Docs
        • camel-aws-kinesis-firehose-sink-kafka-connector
          • Sink Docs
        • camel-aws-kinesis-sink-kafka-connector
          • Sink Docs
        • camel-aws-kinesis-source-kafka-connector
          • Source Docs
        • camel-aws-lambda-sink-kafka-connector
          • Sink Docs
        • camel-aws-polly-sink-kafka-connector
          • Sink Docs
        • camel-aws-redshift-sink-kafka-connector
          • Sink Docs
        • camel-aws-redshift-source-kafka-connector
          • Source Docs
        • camel-aws-s3-event-based-source-kafka-connector
          • Source Docs
        • camel-aws-s3-sink-kafka-connector
          • Sink Docs
        • camel-aws-s3-source-kafka-connector
          • Source Docs
        • camel-aws-s3-streaming-upload-sink-kafka-connector
          • Sink Docs
        • camel-aws-secrets-manager-sink-kafka-connector
          • Sink Docs
        • camel-aws-ses-sink-kafka-connector
          • Sink Docs
        • camel-aws-sns-fifo-sink-kafka-connector
          • Sink Docs
        • camel-aws-sns-sink-kafka-connector
          • Sink Docs
        • camel-aws-sqs-batch-sink-kafka-connector
          • Sink Docs
        • camel-aws-sqs-fifo-sink-kafka-connector
          • Sink Docs
        • camel-aws-sqs-sink-kafka-connector
          • Sink Docs
        • camel-aws-sqs-source-kafka-connector
          • Source Docs
        • camel-aws-timestream-query-sink-kafka-connector
          • Sink Docs
        • camel-aws2-iam-kafka-connector
          • Sink Docs
        • camel-aws2-kms-kafka-connector
          • Sink Docs
        • camel-azure-cosmosdb-sink-kafka-connector
          • Sink Docs
        • camel-azure-cosmosdb-source-kafka-connector
          • Source Docs
        • camel-azure-eventhubs-sink-kafka-connector
          • Sink Docs
        • camel-azure-eventhubs-source-kafka-connector
          • Source Docs
        • camel-azure-functions-sink-kafka-connector
          • Sink Docs
        • camel-azure-servicebus-sink-kafka-connector
          • Sink Docs
        • camel-azure-servicebus-source-kafka-connector
          • Source Docs
        • camel-azure-storage-blob-append-sink-kafka-connector
          • Sink Docs
        • camel-azure-storage-blob-changefeed-source-kafka-connector
          • Source Docs
        • camel-azure-storage-blob-event-based-source-kafka-connector
          • Source Docs
        • camel-azure-storage-blob-sink-kafka-connector
          • Sink Docs
        • camel-azure-storage-blob-source-kafka-connector
          • Source Docs
        • camel-azure-storage-datalake-sink-kafka-connector
          • Sink Docs
        • camel-azure-storage-datalake-source-kafka-connector
          • Source Docs
        • camel-azure-storage-files-sink-kafka-connector
          • Sink Docs
        • camel-azure-storage-files-source-kafka-connector
          • Source Docs
        • camel-azure-storage-queue-sink-kafka-connector
          • Sink Docs
        • camel-azure-storage-queue-source-kafka-connector
          • Source Docs
        • camel-bitcoin-source-kafka-connector
          • Source Docs
        • camel-cassandra-sink-kafka-connector
          • Sink Docs
        • camel-cassandra-source-kafka-connector
          • Source Docs
        • camel-ceph-sink-kafka-connector
          • Sink Docs
        • camel-ceph-source-kafka-connector
          • Source Docs
        • camel-chuck-norris-source-kafka-connector
          • Source Docs
        • camel-couchbase-sink-kafka-connector
          • Sink Docs
        • camel-counter-source-kafka-connector
          • Source Docs
        • camel-cron-source-kafka-connector
          • Source Docs
        • camel-cxf-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-cxfrs-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-databricks-sink-kafka-connector
          • Sink Docs
        • camel-databricks-source-kafka-connector
          • Source Docs
        • camel-dropbox-sink-kafka-connector
          • Sink Docs
        • camel-dropbox-source-kafka-connector
          • Source Docs
        • camel-earthquake-source-kafka-connector
          • Source Docs
        • camel-elasticsearch-index-sink-kafka-connector
          • Sink Docs
        • camel-elasticsearch-search-source-kafka-connector
          • Source Docs
        • camel-exec-sink-kafka-connector
          • Sink Docs
        • camel-fhir-sink-kafka-connector
          • Sink Docs
        • camel-fhir-source-kafka-connector
          • Source Docs
        • camel-file-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-file-watch-source-kafka-connector
          • Source Docs
        • camel-ftp-sink-kafka-connector
          • Sink Docs
        • camel-ftp-source-kafka-connector
          • Source Docs
        • camel-ftps-sink-kafka-connector
          • Sink Docs
        • camel-ftps-source-kafka-connector
          • Source Docs
        • camel-google-bigquery-sink-kafka-connector
          • Sink Docs
        • camel-google-calendar-source-kafka-connector
          • Source Docs
        • camel-google-functions-sink-kafka-connector
          • Sink Docs
        • camel-google-mail-source-kafka-connector
          • Source Docs
        • camel-google-pubsub-sink-kafka-connector
          • Sink Docs
        • camel-google-pubsub-source-kafka-connector
          • Source Docs
        • camel-google-sheets-sink-kafka-connector
          • Sink Docs
        • camel-google-sheets-source-kafka-connector
          • Source Docs
        • camel-google-storage-event-based-source-kafka-connector
          • Source Docs
        • camel-google-storage-sink-kafka-connector
          • Sink Docs
        • camel-google-storage-source-kafka-connector
          • Source Docs
        • camel-google-vertexai-sink-kafka-connector
          • Sink Docs
        • camel-graphql-sink-kafka-connector
          • Sink Docs
        • camel-http-secured-sink-kafka-connector
          • Sink Docs
        • camel-http-secured-source-kafka-connector
          • Source Docs
        • camel-http-sink-kafka-connector
          • Sink Docs
        • camel-http-source-kafka-connector
          • Source Docs
        • camel-https-kafka-connector
          • Sink Docs
        • camel-ibm-cos-sink-kafka-connector
          • Sink Docs
        • camel-ibm-cos-source-kafka-connector
          • Source Docs
        • camel-ibm-watson-language-sink-kafka-connector
          • Sink Docs
        • camel-infinispan-sink-kafka-connector
          • Sink Docs
        • camel-infinispan-source-kafka-connector
          • Source Docs
        • camel-jdbc-kafka-connector
          • Sink Docs
        • camel-jms-amqp-10-sink-kafka-connector
          • Sink Docs
        • camel-jms-amqp-10-source-kafka-connector
          • Source Docs
        • camel-jms-apache-artemis-sink-kafka-connector
          • Sink Docs
        • camel-jms-apache-artemis-source-kafka-connector
          • Source Docs
        • camel-jms-ibm-mq-sink-kafka-connector
          • Sink Docs
        • camel-jms-ibm-mq-source-kafka-connector
          • Source Docs
        • camel-jms-pooled-apache-artemis-sink-kafka-connector
          • Sink Docs
        • camel-jms-pooled-apache-artemis-source-kafka-connector
          • Source Docs
        • camel-kafka-apicurio-registry-not-secured-sink-kafka-connector
          • Sink Docs
        • camel-kafka-apicurio-registry-not-secured-source-kafka-connector
          • Source Docs
        • camel-kafka-azure-schema-registry-sink-kafka-connector
          • Sink Docs
        • camel-kafka-azure-schema-registry-source-kafka-connector
          • Source Docs
        • camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector
          • Source Docs
        • camel-kafka-batch-apicurio-registry-source-kafka-connector
          • Source Docs
        • camel-kafka-batch-azure-schema-registry-source-kafka-connector
          • Source Docs
        • camel-kafka-batch-source-kafka-connector
          • Source Docs
        • camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector
          • Source Docs
        • camel-kafka-not-secured-apicurio-registry-sink-kafka-connector
          • Sink Docs
        • camel-kafka-not-secured-apicurio-registry-source-kafka-connector
          • Source Docs
        • camel-kafka-sink-kafka-connector
          • Sink Docs
        • camel-kafka-source-kafka-connector
          • Source Docs
        • camel-kubernetes-namespaces-source-kafka-connector
          • Source Docs
        • camel-kubernetes-nodes-source-kafka-connector
          • Source Docs
        • camel-kubernetes-pods-source-kafka-connector
          • Source Docs
        • camel-log-sink-kafka-connector
          • Sink Docs
        • camel-mail-imap-source-kafka-connector
          • Source Docs
        • camel-mail-sink-kafka-connector
          • Sink Docs
        • camel-mariadb-sink-kafka-connector
          • Sink Docs
        • camel-mariadb-source-kafka-connector
          • Source Docs
        • camel-minio-sink-kafka-connector
          • Sink Docs
        • camel-minio-source-kafka-connector
          • Source Docs
        • camel-mongodb-changes-stream-source-kafka-connector
          • Source Docs
        • camel-mongodb-sink-kafka-connector
          • Sink Docs
        • camel-mongodb-source-kafka-connector
          • Source Docs
        • camel-mqtt-sink-kafka-connector
          • Sink Docs
        • camel-mqtt-source-kafka-connector
          • Source Docs
        • camel-mqtt5-sink-kafka-connector
          • Sink Docs
        • camel-mqtt5-source-kafka-connector
          • Source Docs
        • camel-mysql-sink-kafka-connector
          • Sink Docs
        • camel-mysql-source-kafka-connector
          • Source Docs
        • camel-nats-sink-kafka-connector
          • Sink Docs
        • camel-nats-source-kafka-connector
          • Source Docs
        • camel-netty-http-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-netty-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-opensearch-index-sink-kafka-connector
          • Sink Docs
        • camel-opensearch-search-source-kafka-connector
          • Source Docs
        • camel-oracle-database-sink-kafka-connector
          • Sink Docs
        • camel-oracle-database-source-kafka-connector
          • Source Docs
        • camel-postgresql-sink-kafka-connector
          • Sink Docs
        • camel-postgresql-source-kafka-connector
          • Source Docs
        • camel-pulsar-sink-kafka-connector
          • Sink Docs
        • camel-pulsar-source-kafka-connector
          • Source Docs
        • camel-redis-sink-kafka-connector
          • Sink Docs
        • camel-redis-source-kafka-connector
          • Source Docs
        • camel-rest-openapi-sink-kafka-connector
          • Sink Docs
        • camel-salesforce-composite-upsert-sink-kafka-connector
          • Sink Docs
        • camel-salesforce-create-sink-kafka-connector
          • Sink Docs
        • camel-salesforce-delete-sink-kafka-connector
          • Sink Docs
        • camel-salesforce-source-kafka-connector
          • Source Docs
        • camel-salesforce-update-sink-kafka-connector
          • Sink Docs
        • camel-scp-sink-kafka-connector
          • Sink Docs
        • camel-sftp-sink-kafka-connector
          • Sink Docs
        • camel-sftp-source-kafka-connector
          • Source Docs
        • camel-sjms2-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-slack-sink-kafka-connector
          • Sink Docs
        • camel-slack-source-kafka-connector
          • Source Docs
        • camel-snowflake-sink-kafka-connector
          • Sink Docs
        • camel-snowflake-source-kafka-connector
          • Source Docs
        • camel-solr-sink-kafka-connector
          • Sink Docs
        • camel-solr-source-kafka-connector
          • Source Docs
        • camel-splunk-hec-sink-kafka-connector
          • Sink Docs
        • camel-splunk-sink-kafka-connector
          • Sink Docs
        • camel-splunk-source-kafka-connector
          • Source Docs
        • camel-spring-rabbitmq-sink-kafka-connector
          • Sink Docs
        • camel-spring-rabbitmq-source-kafka-connector
          • Source Docs
        • camel-sqlserver-sink-kafka-connector
          • Sink Docs
        • camel-sqlserver-source-kafka-connector
          • Source Docs
        • camel-ssh-sink-kafka-connector
          • Sink Docs
        • camel-ssh-source-kafka-connector
          • Source Docs
        • camel-syslog-kafka-connector
          • Source Docs
          • Sink Docs
        • camel-telegram-sink-kafka-connector
          • Sink Docs
        • camel-telegram-source-kafka-connector
          • Source Docs
        • camel-timer-source-kafka-connector
          • Source Docs
        • camel-twitter-directmessage-source-kafka-connector
          • Source Docs
        • camel-twitter-search-source-kafka-connector
          • Source Docs
        • camel-twitter-timeline-source-kafka-connector
          • Source Docs
        • camel-webhook-source-kafka-connector
          • Source Docs
        • camel-wttrin-source-kafka-connector
          • Source Docs
Camel Kafka Connector Next (Pre-release)
  • User manual
  • Camel Core
  • Camel Components
    • Next (Pre-release)
    • 4.22.x (LTS)
    • 4.18.x (LTS)
  • Camel Spring Boot
    • Next (Pre-release)
    • 4.22.x (LTS)
    • 4.18.x (LTS)
  • Camel Quarkus
    • Next (Pre-release)
    • 3.33.x
  • Kamelet Catalog
    • Next (Pre-release)
    • 4.22.x
    • 4.18.x (LTS)
  • Camel K
    • Next (Pre-release)
    • 2.11.x
    • 2.10.x
  • Camel Kafka Connector
    • Next (Pre-release)
  • Camel Karaf
    • 4.9.x
  • Camel Kafka Connector
  • User guide
  • Extending a Connector
Edit this Page
Camel Kafka Connector

Archetypes

There are scenarios in Camel-Kafka-connector and in the Kafka Connect world in general, where an end users needs to extend a connector by adding, for example, a converter or a transformer (or in the camel-kafka-connector case an aggregator).

In camel-kafka-connector we provide multiple archetypes for this purpose.

  • Extensible connector archetype

  • Extensible connector dataformat archetype

  • Extensible connector apicurio archetype

Back to top
Apache Camel Logo Apache Camel

Open source integration framework. An Apache Software Foundation project, available under the Apache v2 license.

Overview+
Blog
Documentation
Tooling
Community
Download
All projects
Documentation+
User Manual
Components
Camel-K
Camel Kafka Connector
Camel Quarkus
Camel Spring Boot
Camel Karaf
FAQ
Community+
Support
Contributing
Mailing Lists
Who Uses Camel
Articles
Books
Team
About+
Acknowledgments
Apache Events
License
Security
Sponsorship
Thanks
Trust

© 2004-2026 The Apache Software Foundation.
Apache Camel, Camel, Apache, the Apache feather logo, and the Apache Camel project logo are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.

Privacy Policy
Code of Conduct
Sitemap