A curated list of Kafka Connect connectors.
Last verified: December 24, 2025 · Legend:
See also: awesome-kafka and Kafka Security Controls to help with CWE, NIST 800-53, and PCI-DSS compliance.
- Databases
- Change Data Capture (CDC)
- Cloud Storage
- Data Warehouses
- Open Table Formats (Lakehouse)
- Search Engines
- Vector Databases
- Time-Series Databases
- Message Queues
- Serverless & Functions
- File Systems
- HTTP & REST
- Network Protocols
- Logging & Monitoring
- Identity & Security
- Caching
- CRM & Marketing
- Developer Tools
- Content Management
- Enterprise Systems
- Social Media
- IoT
- Voice & Telephony
- Audio
- Industrial & SCADA
- Blockchain
- Gaming & Entertainment
- Document Processing
- Data Formats & Transformations
- Data Generators & Testing
- Real-Time Data Platforms
- Healthcare (HL7/FHIR)
- GIS & Geospatial
- Machine Learning & Feature Stores
- Data Catalogs
- DevOps & Infrastructure
- Multi-Connector Packages
- confluentinc/kafka-connect-jdbc - Confluent's JDBC source and sink connector supporting MySQL, PostgreSQL, Oracle, SQL Server, DB2, SQLite, and more
- Aiven-Open/jdbc-connector-for-apache-kafka - Aiven's JDBC sink and source connectors for Apache Kafka
- Debezium JDBC Sink - Debezium's JDBC sink connector supporting multiple databases
- mongodb/mongo-kafka - Official MongoDB Kafka Connector (source and sink)
⚠️ hpgrahsl/kafka-connect-mongodb - Community MongoDB sink connector⚠️ DataReply/kafka-connect-mongodb - MongoDB source and sink using oplog- 📦 teambition/kafka-connect-mongo - MongoDB source with Schema Registry support (archived)
- datastax/kafka-sink - DataStax Apache Kafka Connector for Apache Cassandra and DataStax Enterprise
- neo4j-contrib/neo4j-streams - Neo4j Kafka Streams integration with Kafka Connect sink
- tigergraph/ecosys - TigerGraph Kafka Connect connector (in tools/etl/tg-kafka-connect)
⚠️ rayokota/janusgraph-kafka - Kafka storage adapter for JanusGraph graph database
- ClickHouse/clickhouse-kafka-connect - Official ClickHouse Kafka Connect sink connector
- Works with JDBC connector using PostgreSQL wire protocol
- memsql/singlestore-kafka-connector - Official SingleStore Kafka Connector
- couchbase/kafka-connect-couchbase - Official Couchbase Kafka Connector (source and sink)
⚠️ xebia/kafka-connect-couchdb - CouchDB / IBM Cloudant sink connector
- microsoft/kafka-connect-cosmosdb - Azure Cosmos DB sink connector for SQL API
- marklogic-community/kafka-marklogic-connector - MarkLogic Kafka Connector
- scylladb/kafka-connect-scylladb - Scylla-optimized sink connector
⚠️ jcustenborder/kafka-connect-aerospike - Aerospike source and sink connector
- arangodb/kafka-connect-arangodb - Official ArangoDB Kafka Connect sink connector with automatic collection and index creation
⚠️ jaredpetersen/kafka-connect-arangodb - Community Kafka Connect sink connector for ArangoDB
- Memgraph includes native Kafka integration via built-in Kafka Streams within its MAGE (Memgraph Advanced Graph Extensions) library for real-time graph analytics
- vesoft-inc/nebula-exchange - NebulaGraph Exchange with Kafka source support for bulk data migration via Apache Spark
- Community JDBC-based integrations available
- Cloudera HBase sink connector (commercial)
- Confluent DynamoDB Sink - Confluent DynamoDB sink connector (commercial)
- 📦 trustpilot/kafka-connect-dynamodb - Open source DynamoDB sink connector
⚠️ yugabyte/yb-kafka-connector - YugabyteDB Kafka Connect sink connector- yugabyte/debezium-connector-yugabytedb - Debezium CDC source connector for YugabyteDB
⚠️ onfocusio/kafka-connect-kudu - Apache Kudu sink connector
⚠️ jcustenborder/kafka-connect-rethinkdb - RethinkDB sink connector- Lenses Stream Reactor includes RethinkDB source (changefeed) and sink connectors
- Works with MySQL JDBC connector or Debezium MySQL connector (MySQL protocol compatible)
- pingcap/tidb-binlog - TiDB binlog tools for CDC to Kafka
- MaterializeInc/materialize - Streaming database with native Kafka source support for incremental view maintenance
- debezium/debezium - Leading CDC platform with connectors for MySQL, PostgreSQL, MongoDB, Oracle, SQL Server, Db2, Cassandra, Vitess, Spanner
- zendesk/maxwell - Maxwell's daemon for MySQL CDC to Kafka
- alibaba/canal - Alibaba MySQL binlog incremental subscription & consumption
- confluentinc/kafka-connect-jdbc - Query-based CDC using incrementing/timestamp columns
- thake/logminer-kafka-connect - Oracle CDC using LogMiner (no GoldenGate required)
⚠️ imanzano/GoldenGateConfluentKafkaConnector - Oracle GoldenGate Kafka Connect handler for Confluent (for GoldenGate versions prior to 12.3.1)- Oracle GoldenGate for Big Data - Official Kafka Connect Handler (commercial, included in GoldenGate 12.3.1+)
- jhc-systems/debezium-connector-ibmi - Debezium CDC connector for IBM i (AS/400) using journals
- confluentinc/kafka-connect-storage-cloud - Confluent's S3 sink connector
- Aiven-Open/cloud-storage-connectors-for-apache-kafka - Aiven's cloud storage connectors (S3, GCS, Azure)
⚠️ wix-incubator/kafka-connect-s3 - S3 sink with block-GZIP compression and index files⚠️ llofberg/kafka-connect-s3-parquet - S3 source connector reading Parquet files⚠️ byegor/kafka-connect-s3-orc - S3 source connector reading ORC files
- confluentinc/kafka-connect-storage-cloud - Confluent's GCS sink connector
- Aiven-Open/cloud-storage-connectors-for-apache-kafka - Aiven's GCS connector
- confluentinc/kafka-connect-storage-cloud - Confluent's Azure Blob sink connector
- Aiven-Open/cloud-storage-connectors-for-apache-kafka - Aiven's Azure Blob connector
- Works with any S3-compatible connector
- snowflakedb/snowflake-kafka-connector - Official Snowflake Kafka Connector
- Aiven-Open/bigquery-connector-for-apache-kafka - Aiven's BigQuery sink connector
- wepay/kafka-connect-bigquery - WePay BigQuery sink connector
- confluentinc/kafka-connect-bigquery - Confluent Hub version
⚠️ nodefluent/bigquery-kafka-connect - Node.js BigQuery source and sink connector
- Aiven-Open/jdbc-connector-for-apache-kafka - Via JDBC
- Confluent Redshift sink connector (commercial)
- databricks/databricks-sql-connector - Databricks SQL connector
- Works with Delta Lake connector for direct lakehouse integration
- Azure/kafka-sink-azure-kusto - Azure Data Explorer sink connector
⚠️ mhomaid/kafka-connect-apache-pinot - Community sink connector for Apache Pinot
⚠️ gianm/kafka-connect-druid - Early-stage Apache Druid sink connector
- StarRocks/starrocks-connector-for-kafka - Official StarRocks Kafka Connect sink connector
- apache/doris-kafka-connector - Official Apache Doris Kafka Connect sink connector
- databendcloud/databend-kafka-connect - Databend Kafka Connect sink connector
- Confluent Teradata connector (commercial) - JDBC-based source and sink
- Confluent Vertica connector (commercial)
- 📦 exasol/kafka-connect-jdbc-exasol - Example configuration for Kafka Connect JDBC with Exasol driver
- exasol/kafka-connector-extension - Exasol extension for Kafka data ingestion
- tabular-io/iceberg-kafka-connect - Tabular's Iceberg Kafka Connect sink
- 📦 getindata/kafka-connect-iceberg-sink - GetInData's Iceberg sink connector
- apache/hudi - Includes DeltaStreamer for Kafka ingestion
- hudi-kafka-connect - Official Hudi Kafka Connect sink
- delta-io/delta - Delta Lake with Spark Streaming Kafka integration
- confluentinc/kafka-connect-elasticsearch - Confluent's Elasticsearch sink connector
- Aiven-Open/elasticsearch-connector-for-apache-kafka - Aiven's Elasticsearch sink connector
- Aiven-Open/opensearch-connector-for-apache-kafka - Aiven's OpenSearch connector
- 📦 dmathieu/kafka-connect-opensearch - Community OpenSearch connector
⚠️ jcustenborder/kafka-connect-solr - Solr sink connector with schemaless and cloud mode support
- zilliztech/kafka-connect-milvus - Milvus Kafka Connect sink connector
- weaviate/weaviate - Kafka Connect integration available
- Pinecone Kafka Connect sink connector (commercial)
- qdrant/qdrant-kafka - Qdrant vector database sink connector
⚠️ influxdata/kafka-connect-influxdb - Official InfluxDB sink connector
- Works with PostgreSQL JDBC connector
- questdb/kafka-questdb-connector - Official QuestDB Kafka Connect sink
- ibm-messaging/kafka-connect-mq-source - Official IBM MQ source connector
- ibm-messaging/kafka-connect-mq-sink - Official IBM MQ sink connector
- ibm-messaging/kafka-connect-rabbitmq-source - IBM's RabbitMQ source connector
- Confluent RabbitMQ source connector (commercial)
- macronova/kafka-connect-jms - JMS connector supporting ActiveMQ
- macronova/kafka-connect-jms - Generic JMS source and sink for IBM MQ, ActiveMQ, TIBCO EMS, Solace PubSub, RabbitMQ
⚠️ evokly/kafka-connect-mqtt - MQTT source connector using Eclipse Paho- Confluent MQTT source connector (commercial)
- Confluent SQS source/sink connectors (commercial)
⚠️ awslabs/kinesis-kafka-connector - Sink connector for Kinesis Data Streams and Firehose
⚠️ oystparis/kafka-connect-nats - NATS source and sink connector
- aws/eventbridge-kafka-connector - Sink connector for Amazon EventBridge with S3 offloading
- 📦 streamnative/pulsar-io-kafka - Pulsar IO connector for consuming from or publishing to Kafka topics (bridge)
⚠️ bigdatafly/kafka-rocketmq-source - Kafka Connect source for RocketMQ
- googleapis/java-pubsub-group-kafka-connector - Official Google Pub/Sub Kafka connector
- Confluent Pub/Sub connector (commercial)
- research-virtualfortknox/simple-kafka-msb-connector - Kafka to Azure Service Bus bridge (topics <-> queues)
- Works natively via Kafka protocol support in Azure Event Hubs
- SolaceProducts/pubsubplus-connector-kafka-source - Solace PubSub+ source connector
- SolaceProducts/pubsubplus-connector-kafka-sink - Solace PubSub+ sink connector
⚠️ llofberg/kafka-connect-aws-lambda - AWS Lambda sink connector invoking functions with Kafka records
- 📦 fcarp10/kafka-connectors - Firebase and Elasticsearch connectors for Kafka Connect
- Confluent Firebase Connector (commercial) - Firebase Realtime Database source and sink
- streamthoughts/kafka-connect-file-pulse - Multipurpose connector for CSV, JSON, XML, Avro files from local, S3, GCS, Azure
- jcustenborder/kafka-connect-spooldir - Watch directories for CSV, JSON, binary files
⚠️ mmolimar/kafka-connect-fs - FileSystem connector for local, HDFS, FTP, S3, GCS, Azure
⚠️ mglaserna/kafka-connect-sftp - SFTP sink connector- Confluent SFTP source connector (commercial)
- confluentinc/kafka-connect-hdfs - Confluent's HDFS sink connector
- Aiven-Open/http-connector-for-apache-kafka - Aiven's HTTP sink connector
- castorm/kafka-connect-http - HTTP source for Change Data Capture from JSON APIs
⚠️ llofberg/kafka-connect-rest - REST source and sink connector⚠️ asaintsever/kafka-connect-http-sink - HTTP sink connector⚠️ thomaskwscott/kafka-connect-http - HTTP sink connector with regex transformations- axual/http-sink-connector - Axual HTTP sink connector (GitLab)
- Platformatory/webhook-source-connector - Webhook source connector with Netty HTTP server
⚠️ jcustenborder/kafka-connect-servlet - Framework for building webhook-based connectors with embedded Jetty⚠️ jcustenborder/kafka-connect-github-webhook - GitHub webhook source connector⚠️ kaliy/kafka-connect-rss - RSS/Atom feed source connector- Confluent HTTP source and sink connectors (commercial)
- vrudenskyi/kafka-connect-netty-source - Netty-based source connector supporting TCP and UDP with configurable protocol handlers
⚠️ dhanuka84/kafka-connect-tcp - TCP socket source connector⚠️ daniellavoie/kafka-connect-udp - UDP source connector (no ordering guarantees, cannot run in distributed mode)- Confluent Data Diode connector (commercial) - Unidirectional Kafka-to-Kafka replication over UDP for high-security environments
⚠️ evolv34/kafka-connect-ws - WebSocket source connector for streaming real-time data
- 📦 jorgechato/kafka-connect-graphql - GraphQL source connector with Avro serialization and Schema Registry support
- Apache Camel GraphQL Sink Connector via camel-kafka-connector
⚠️ jcustenborder/kafka-connect-netflow - NetFlow v5/v9 and IPFIX source connector for network traffic analysis
- splunk/kafka-connect-splunk - Official Splunk sink connector
- DataDog/datadog-kafka-connect - Datadog logs sink connector
- newrelic/kafka-connect-newrelic - New Relic sink connector
⚠️ jeschkies/kafka-connect-loki - Loki sink connector for log aggregation
- 📦 humio/kafka-connect-hec-sink - HTTP Event Collector (HEC) sink to LogScale/Humio
- conduktor/kafka-connect-opentelemetry - Source connector ingesting OTLP traces/metrics/logs into Kafka
- SumoLogic/sumologic-kafka-push - Utility for reading logs from Kafka and sending to Sumo Logic
⚠️ Atulya1/Kafka-Oauth2 - Okta OAuth2-protected REST source connector example
- SnuK87/keycloak-kafka - Keycloak SPI module that publishes authentication events to Kafka topics
- jcustenborder/kafka-connect-redis - Redis sink connector
- 📦 hazelcast/hazelcast-jet-contrib - Hazelcast Jet connectors for Kafka
⚠️ apache/geode-kafka-connector - Apache Geode sink and source connector
⚠️ jcustenborder/kafka-connect-memcached - Memcached sink connector
- Apache Ignite includes IgniteSinkConnector for streaming data from Kafka to Ignite caches
⚠️ nodefluent/salesforce-kafka-connect - Node.js Salesforce source and sink connector- Confluent Salesforce connectors (commercial)
- 📦 IBM/kafka-connect-servicenow - ServiceNow source connector
- Confluent ServiceNow source connector (commercial)
- Confluent Zendesk source connector (commercial)
- Confluent Marketo source connector (commercial)
⚠️ segment-integrations/connect-kafka - Segment destination for sending events to Kafka
⚠️ MrTrustworthy/kafka-connect-googleanalytics - Google Analytics Reporting API source connector
⚠️ cpard/kafka-connect-mixpanel - Mixpanel events sink connector
⚠️ ecerulm/kafka-connect-amplitude - Amplitude Batch Upload API sink connector
- sami12rom/kafka-connect-gitlab - GitLab source connector built with Kotlin
⚠️ simplesteph/kafka-connect-github-source - GitHub events source connector
⚠️ algru/kafka-jira-source-connector - Jira REST API source connector
- 📦 dgcaron/kafka-connect-contentful - Contentful CMS source connector using the Sync API
⚠️ atomotic/airtable-cdc-kafka - Airtable CDC source using HTTP connector to poll Airtable API for modified records
- SAP/kafka-connect-sap - Official SAP HANA source and sink connector
⚠️ santi81/kafka-connect-hana - Alternative SAP HANA source and sink connector
- Works with Debezium Oracle connector or JDBC connector
- jhc-systems/debezium-connector-ibmi - Debezium CDC connector for IBM i using journals
- Infoview Systems infoConnect for Kafka (commercial) - Data queue source/sink and program call connectors
- Confluent TIBCO EMS source and sink connectors (commercial)
- macronova/kafka-connect-jms - JMS connector supporting TIBCO EMS
- 📦 oracle/coherence-kafka - Official Oracle Coherence sink connector and cache store
⚠️ Mongey/kafka-connect-slack - Slack sink connector for posting messages
- fbascheper/kafka-connect-telegram - Telegram source and sink connector
⚠️ jcustenborder/kafka-connect-twitter - Twitter streaming API source connector
⚠️ cloudstark/kafka-connect-twilio - Twilio SMS sink connector
⚠️ C0urante/kafka-connect-reddit - Reddit source connector streaming posts and comments from subreddits
⚠️ jcustenborder/kafka-connect-email - IMAP email source connector⚠️ wardziniak/kafka-connect-email - SMTP email sink connector⚠️ cloudstark/kafka-connect-sendgrid - SendGrid sink connector
⚠️ jcustenborder/kafka-connect-snmp - SNMP trap source connector for network device monitoring
⚠️ gnostix/kafka-connect-asterisk - Asterisk PBX source connector retrieving CDRs and call events via AMI- 📦 retel-io/ari-proxy - Asterisk ARI to Kafka bridge for call control events
⚠️ voiceip/mod_event_kafka - FreeSWITCH plugin publishing all events to Kafka
⚠️ C0urante/kafka-connect-sound - Fun audio sink connector that converts Kafka messages into sound through MIDI
- apache/plc4x - Apache PLC4X Kafka Connect integration supporting OPC-UA, Modbus, Siemens S7, Allen Bradley, and 30+ industrial protocols
⚠️ kaiwaehner/ksql-udf-deep-learning-mqtt-iot - Reference architecture for IIoT with PLC4X, Kafka Connect, and KSQL- industrial-edge/Apache-Kafka-Connector - Siemens Industrial Edge connector for streaming PLC data to Kafka
- hyperledger-labs/hlf-connector - Hyperledger Fabric Kafka Connect source connector
⚠️ dalelane/kafka-connect-xboxlive-source - Xbox Live activity feed source connector streaming gaming events
⚠️ DataReply/kafka-connect-document-source - Document extraction source connector supporting PDF, Word, and other document formats via Apache Tika
- Aiven-Open/transforms-for-apache-kafka-connect - Aiven's collection of Single Message Transformations (SMTs)
- jcustenborder/kafka-connect-transform-common - Common transformations library
- jcustenborder/kafka-connect-transform-maxmind - MaxMind GeoIP2 transform to enrich records with geolocation data
⚠️ jcustenborder/kafka-connect-transform-archive - Transform to assist with archiving records to S3⚠️ jcustenborder/kafka-connect-transform-xml - Transform for converting XML data to structured data⚠️ jcustenborder/kafka-connect-transform-fix - Transform for reading FIX protocol messages⚠️ jcustenborder/kafka-connect-opentsdb - Transform for parsing OpenTSDB wire format and telnet API protocol
- confluentinc/kafka-connect-datagen - Confluent's datagen source connector for generating mock data with Avro schemas, JSON, or Protobuf
⚠️ MichaelDrogalis/voluble - Intelligent data generator with cross-topic relationships, tombstoning, and configurable rates- awslabs/amazon-msk-data-generator - AWS MSK data generator (Java port of Voluble) with referential consistency
⚠️ sasakitoa/kafka-connect-random - Simple random value source connector⚠️ simplesteph/kafka-connect-github-source - GitHub issues and pull requests source connector⚠️ conduktor/kafka-connect-wikimedia - Wikimedia recent changes stream source connector
- pushtechnology/diffusion-kafka-connect - Push Technology Diffusion source and sink for real-time streaming to web, mobile, and IoT edge clients
- axual/kafka-synchronisation-connectors - Source and sink connectors for cross-cluster Kafka replication (GitLab)
⚠️ kakao/kafka-sink-connector - Kafka-to-Kafka sink with JsonPath filtering and sampling
⚠️ jcustenborder/kafka-connect-transform-hl7 - Transform for reading HL7 healthcare message structures- UMEssen/Volcano-HL7-MLLP-Connector - High-performance HL7 v2 MLLP listener to Kafka (Scala)
- Apache Camel FHIR Kafka Connector via camel-kafka-connector
⚠️ planetfederal/kafka-geoserver-plugin - GeoServer plugin sending WFS-T transactions to Kafka- 📦 52North/postgis-kafka-cdc - PostGIS CDC with Debezium (experimental)
- Debezium PostgreSQL connector supports PostGIS data types natively
⚠️ dwarszawski/kafka-connect-mlflow - MLflow Model Registry change tracking source connector- Feast (Feature Store) integrates with Kafka for real-time feature ingestion
⚠️ jhollandus/kafka-atlas - POC for integrating Kafka Connect and Schema Registry with Apache Atlas- DataHub ingests Kafka Connect metadata for lineage tracking
⚠️ midhun1998/kafka-connect-kubernetes-events - Kubernetes events source connector⚠️ AmadeusITGroup/Kubernetes-Kafka-Connect-Operator - Kubernetes operator for deploying and auto-scaling Kafka Connect- strimzi/strimzi-kafka-operator - CNCF Kubernetes operator with KafkaConnector CRD support
⚠️ jcustenborder/kafka-config-provider-vault - Kafka config provider for retrieving secrets from Vault (supports approle, kubernetes, token, ldap, gcp, aws auth)- 📦 convoyinc/KafkaVaultProvider - Kafka config provider for Vault API integration
⚠️ openzipkin-contrib/brave-kafka-interceptor - Zipkin tracing interceptors for Kafka Connect and producers/consumers- Strimzi supports OpenTelemetry tracing with Jaeger backend for Kafka Connect
- Mongey/terraform-provider-kafka-connect - Terraform provider for managing Kafka Connect connectors
- 📦 b-social/terraform-provider-kafkaconnect - Alternative Terraform provider for Kafka Connect
- lensesio/stream-reactor - 30+ connectors covering S3/GCS/Azure storage, Cassandra/HBase/Kudu, Elasticsearch/Solr, InfluxDB, JMS/MQTT, FTP/SFTP, Redis, MongoDB, blockchain/IoT, and more
- Aiven-Open - Open source connectors for BigQuery, cloud storage (S3/GCS/Azure), Elasticsearch, HTTP, JDBC, OpenSearch, plus SMTs and Kafka tools
- apache/camel-kafka-connector - 350+ connectors built on Apache Camel components, supporting AWS, Azure, GCP, databases, messaging systems, social media, and more
- camunda-community-hub/kafka-connect-zeebe - Zeebe source and sink connectors for workflow automation with Camunda
- redpanda-data/connect - Benthos-based declarative connectors for 200+ sources/sinks (Kafka compatible)
Contributions welcome! Please read the contribution guidelines first.
