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:

• 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
• 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

Preview connectors

Some connectors have a preview tag. Preview connectors are not covered by our SLA, so consider this before using them in production environments. Report bugs directly to the code owner.

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

tip

When requesting connectors not on the pre-approved list, specify the target Aiven for Apache Kafka service.

---

Elasticsearch is a trademark of Elasticsearch B.V., registered in the U.S. and in other countries.

Couchbase is a trademark of Couchbase, Inc.