云消息队列 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 版导出,同步至函数计算。 | |
MaxCompute Sink Connector | 将数据从云消息队列 Kafka 版导出,同步至大数据计算服务MaxCompute。 | |
OSS Sink Connector | 将数据从云消息队列 Kafka 版导出,同步至对象存储OSS。 | |
Elasticsearch Sink Connector | 将数据从云消息队列 Kafka 版导出,同步至阿里云Elasticsearch。 | |
Tablestore Sink Connector | 将数据从云消息队列 Kafka 版实例的数据源Topic导出,同步至表格存储(Tablestore)。 | |
SLS Sink Connector | 将数据从云消息队列 Kafka 版导出,同步至日志服务(SLS)。 | |
AnalyticDB Sink Connector | 将数据从云消息队列 Kafka 版导出,同步至云原生数据仓库 AnalyticDB MySQL 版或云原生数据仓库AnalyticDB PostgreSQL版。 |