Available Apache Kafka® Connect connectors
Discover a variety of connectors available for use with any Aiven for Apache Kafka® service with Apache Kafka® Connect enabled.
Source connectors
Source connectors enable the integration of data from an existing technology into an Apache Kafka topic. The available source connectors include:
- Amazon S3 source connector
- Couchbase
- Debezium for MongoDB®
- Debezium for MySQL
- Debezium for PostgreSQL®
- Debezium for SQL Server
- Debezium for PostgreSQL with TLS support
- Debezium for PostgreSQL with node replacement
- Google Cloud Pub/Sub
- Google Cloud Pub/Sub Lite
- JDBC source for MySQL
- JDBC source for PostgreSQL
- JDBC source for SQL Server
- MongoDB Kafka Connector (Official) (supports both source and sink functionality)
- Stream Reactor Cassandra®
- Stream Reactor MQTT
Sink connectors
Sink connectors enable the integration of data from an existing Apache Kafka topic to a target technology. The available sink connectors include:
- Amazon S3 sink connector
- Azure Blob Storage sink connector
- ClickHouse sink connector
- Confluent Amazon S3 sink
- Couchbase®
- Elasticsearch
- Google BigQuery
- Google Cloud Pub/Sub
- Google Cloud Pub/Sub Lite
- Google Cloud Storage
- HTTP
- IBM MQ sink connector
- Iceberg sink connector
- InfluxDB sink connector
- JDBC sink
- MongoDB sink (Lenses)
- OpenSearch®
- Snowflake
- Splunk
- Stream Reactor Cassandra®
- Stream Reactor InfluxDB®
- Stream Reactor MongoDB®
- Stream Reactor MQTT
- Stream Reactor Redis®*
- S3 IAM Assume Role
Requesting new connectors
If there are connectors you'd like us to support, submit a support request. Your feedback helps shape our roadmap. To request a new connector, create a support ticket.
Aiven evaluates new Apache Kafka Connect connectors based on:
- License compatibility
- Technical implementation
- Active repository maintenance
When requesting connectors not on the pre-approved list, specify the target Aiven for Apache Kafka service.
Couchbase is a trademark of Couchbase, Inc.