ApsaraMQ for Kafka provides fully managed and O&M-free sink connectors to synchronize data between ApsaraMQ for Kafka and other Alibaba Cloud services. This topic describes the prerequisites for using sink connectors and the types of data synchronization tasks that are supported by sink connectors.
Prerequisites
Sink connectors are implemented based on EventBridge and Function Compute. Before you use a sink connector, make sure that the following services are activated:
- Activate EventBridge and grant permissions to a RAM user
- Function Compute is activated. For more information, see Activate Function Compute.
Billing
- EventBridge is in public preview. It is free of charge during public preview.
- For information about the billing of Function Compute, see Billing overview.
Connector types
Sink in sink connectors indicates data outflow. When you use the sink connectors provided by Message Queue for Apache Kafka, ApsaraMQ for Kafka serves as the data sources, and other services serve as the data destinations. The following table describes the types of sink connectors.
| Connector | Description | References |
|---|---|---|
| Function Compute sink connector | Synchronizes data from ApsaraMQ for Kafka to Function Compute. | Create Function Compute sink connectors |
| MaxCompute sink connector | Synchronizes data from ApsaraMQ for Kafka to MaxCompute. | Create MaxCompute sink connectors |
| OSS sink connector | Synchronizes data from ApsaraMQ for Kafka to Object Storage Service (OSS). | Create OSS sink connectors |
| Elasticsearch sink connector | Synchronizes data from ApsaraMQ for Kafka to Elasticsearch. | Create Elasticsearch sink connectors |
| Tablestore sink connector | Synchronizes data from ApsaraMQ for Kafka to Tablestore. | Create Tablestore sink connectors |
| Log Service sink connector | Synchronizes data from ApsaraMQ for Kafka to Log Service. | Create Log Service sink connectors |
| AnalyticDB sink connector | Synchronizes data from ApsaraMQ for Kafka to AnalyticDB for MySQL or AnalyticDB for PostgreSQL. | Create AnalyticDB sink connectors |