云消息隊列 Kafka 版提供全托管、免運維的Connector,用于云消息隊列 Kafka 版和其他阿里云服務之間的數據同步。本文介紹Connector支持的數據同步任務的類型、使用流程、使用限制以及跨地域數據同步。
云消息隊列 Kafka 版的Connector組件處于公測階段,且獨立于云消息隊列 Kafka 版實例,因此不會在云消息隊列 Kafka 版側產生費用。同時,阿里云不承諾Connector的SLA,使用Connector所依賴的其他產品的SLA和費用說明請以對應產品為準。
Connector類型
云消息隊列 Kafka 版支持以下兩大類的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。
DLA Sink Connector
將數據從云消息隊列 Kafka 版導出,同步至云原生數據湖分析DLA(Data Lake Analytics)。
Tablestore Sink Connector
將數據從云消息隊列 Kafka 版實例的數據源Topic導出,同步至表格存儲(Tablestore)。
AnalyticDB Sink Connector
將數據從云消息隊列 Kafka 版實例的數據源Topic導出,同步至云原生數據倉庫 AnalyticDB MySQL 版或云原生數據倉庫 AnalyticDB PostgreSQL 版。
Source Connector:Source代表數據向內流轉,即云消息隊列 Kafka 版為數據目標,其他產品為數據源。
Connector
描述
文檔
MySQL Source Connector
將數據從阿里云數據庫RDS MySQL版導出,同步至云消息隊列 Kafka 版。
使用流程
Connector的使用流程如下:
使用限制
云消息隊列 Kafka 版對Connector的限制如下:
項目 | 限制值 |
數量 | 單實例最多創建20個。您可以創建多個Connector任務將同一實例的數據導出到不同的服務中。 |
地域 | 該功能目前有個別地域未開通。具體信息,請參見開服地域。 |
跨地域數據同步
如果您需要將某個地域的數據,通過Connector同步到另一個地域的阿里云服務,您需要為該Connector開啟公網訪問,然后在公網進行數據同步。具體操作步驟,請參見為Connector開啟公網訪問。
MySQL Source Connector的跨地域數據同步比較特殊,需要您自行開通企業網。更多信息,請參見創建MySQL Source Connector。