云消息队列 Kafka 版提供全托管、免运维的Sink Connector,用于云消息队列 Kafka 版和其他阿里云服务之间的数据同步。本文介绍使用Connector时的注意事项及支持的数据同步任务类型。

前提条件

Connector底层基于事件总线EventBridge函数计算FC(Function Compute)实现,在使用Connector之前,请确保已开通以下服务。

计费说明

  • 事件总线EventBridge目前处于公测中,免费使用。
  • 函数计算FC(Function Compute)的计费说明,请参见计费概述

Connector类型

Sink Connector中的Sink代表数据向外流转,即云消息队列 Kafka 版为数据源,其他产品为数据目标。

Connector描述文档
FC Sink Connector将数据从云消息队列 Kafka 版导出,同步至函数计算。创建FC Sink Connector
MaxCompute Sink Connector将数据从云消息队列 Kafka 版导出,同步至大数据计算服务MaxCompute。创建MaxCompute Sink Connector
OSS Sink Connector将数据从云消息队列 Kafka 版导出,同步至对象存储OSS。创建OSS Sink Connector
Elasticsearch Sink Connector将数据从云消息队列 Kafka 版导出,同步至阿里云Elasticsearch。创建Elasticsearch Sink Connector
Tablestore Sink Connector将数据从云消息队列 Kafka 版实例的数据源Topic导出,同步至表格存储(Tablestore)。创建Tablestore Sink Connector
SLS Sink Connector将数据从云消息队列 Kafka 版导出,同步至日志服务(SLS)。创建SLS Sink Connector
AnalyticDB Sink Connector将数据从云消息队列 Kafka 版导出,同步至云原生数据仓库AnalyticDB MySQL版或云原生数据仓库AnalyticDB PostgreSQL版。创建AnalyticDB Sink Connector