消息队列Kafka版提供全托管、免运维的Connector,用于同一地域内的消息队列Kafka版和其他阿里云服务之间的数据同步。Connector当前处于公测阶段。本文介绍Connector的类型、使用流程、使用限制以及跨地域数据同步。

Connector类型

消息队列Kafka版目前仅提供Sink Connector,用于将数据从消息队列Kafka版导出至其他阿里云服务。消息队列Kafka版支持以下类型的Sink Connector:

Sink Connector类型 任务类型 描述 文档
FC Sink Connector KAFKA2FC 将数据从消息队列Kafka版导出至函数计算。 创建FC Sink Connector
MaxCompute Sink Connector KAFKA2ODPS 将数据从消息队列Kafka版导出至大数据计算服务MaxCompute。 创建MaxCompute Sink Connector

使用流程

Connector的使用流程如下:

  1. 开启Connector

    开启Connector

  2. 创建Connector
  3. 管理Connector

使用限制

消息队列Kafka版对Connector的限制如下:

项目 限制值
数量 3
地域
  • 华东1(杭州)
  • 华东2(上海)
  • 华北2(北京)
  • 华北3(张家口)
  • 华北5(呼和浩特)
  • 华南1(深圳)
  • 西南1(成都)
  • 中国香港
  • 新加坡(新加坡)
  • 日本(东京)
说明 如果您需要提升您的实例的Connector的数量限制或者需要更多的地域,请提交工单工单联系消息队列Kafka版技术人员。

跨地域数据同步

如果您需要将某个地域的Connector的数据同步到另一个地域的阿里云服务,您需要为该Connector开启公网访问,然后在公网进行数据同步。详情请参见为Connector开启公网访问