All Products
Search
Document Center

:Connector overview

Last Updated:Aug 29, 2026

ApsaraMQ for Kafka provides fully managed Sink connectors. You can use these connectors to synchronize data between ApsaraMQ for Kafka and other Alibaba Cloud services. This topic describes important information about using connectors and lists the supported data synchronization tasks.

Prerequisites

Connectors are built on EventBridge and Function Compute (FC). Before you use connectors, you must activate the following services.

Billing

  • EventBridge is in public preview and is free to use.

  • For more information about billing for Function Compute (FC), see Billing overview.

Connector types

The "Sink" in Sink connector indicates that data flows outward. For this type of connector, ApsaraMQ for Kafka is the data source and other products are the data targets.

Connector

Description

Document

FC Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to Function Compute.

Create an FC Sink Connector

MaxCompute Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to MaxCompute.

Create a MaxCompute Sink Connector

OSS Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to Object Storage Service (OSS).

Create an OSS Sink Connector

Elasticsearch Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to Alibaba Cloud Elasticsearch.

Create an Elasticsearch Sink Connector

Tablestore Sink Connector

Exports data from a source topic of an ApsaraMQ for Kafka instance and synchronizes it to Tablestore.

Create a Tablestore Sink Connector

SLS Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to Simple Log Service (SLS).

Create an SLS Sink Connector

AnalyticDB Sink Connector

Exports data from ApsaraMQ for Kafka and synchronizes it to AnalyticDB for MySQL or AnalyticDB for PostgreSQL.

Create an AnalyticDB Sink Connector