舊版Connector
云消息隊(duì)列 Kafka 版提供全托管、免運(yùn)維的Connector,用于云消息隊(duì)列 Kafka 版和其他阿里云服務(wù)之間的數(shù)據(jù)同步。本文介紹Connector支持的數(shù)據(jù)同步任務(wù)的類(lèi)型、使用流程、使用限制以及跨地域數(shù)據(jù)同步。
云消息隊(duì)列 Kafka 版的Connector組件處于公測(cè)階段,且獨(dú)立于云消息隊(duì)列 Kafka 版實(shí)例,因此不會(huì)在云消息隊(duì)列 Kafka 版側(cè)產(chǎn)生費(fèi)用。同時(shí),阿里云不承諾Connector的SLA,使用Connector所依賴的其他產(chǎn)品的SLA和費(fèi)用說(shuō)明請(qǐng)以對(duì)應(yīng)產(chǎn)品為準(zhǔn)。
Connector類(lèi)型
云消息隊(duì)列 Kafka 版支持以下兩大類(lèi)的Connector:
Sink Connector:Sink代表數(shù)據(jù)向外流轉(zhuǎn),即云消息隊(duì)列 Kafka 版為數(shù)據(jù)源,其他產(chǎn)品為數(shù)據(jù)目標(biāo)。
Connector
描述
文檔
FC Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版導(dǎo)出,同步至函數(shù)計(jì)算。
MaxCompute Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版導(dǎo)出,同步至大數(shù)據(jù)計(jì)算服務(wù)MaxCompute。
OSS Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版導(dǎo)出,同步至對(duì)象存儲(chǔ)OSS。
Elasticsearch Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版導(dǎo)出,同步至阿里云Elasticsearch。
Tablestore Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版實(shí)例的數(shù)據(jù)源Topic導(dǎo)出,同步至表格存儲(chǔ)(Tablestore)。
AnalyticDB Sink Connector
將數(shù)據(jù)從云消息隊(duì)列 Kafka 版實(shí)例的數(shù)據(jù)源Topic導(dǎo)出,同步至云原生數(shù)據(jù)倉(cāng)庫(kù) AnalyticDB MySQL 版或云原生數(shù)據(jù)倉(cāng)庫(kù) AnalyticDB PostgreSQL 版。
Source Connector:Source代表數(shù)據(jù)向內(nèi)流轉(zhuǎn),即云消息隊(duì)列 Kafka 版為數(shù)據(jù)目標(biāo),其他產(chǎn)品為數(shù)據(jù)源。
Connector
描述
文檔
MySQL Source Connector
將數(shù)據(jù)從阿里云數(shù)據(jù)庫(kù)RDS MySQL版導(dǎo)出,同步至云消息隊(duì)列 Kafka 版。
使用流程
Connector的使用流程如下:
使用限制
云消息隊(duì)列 Kafka 版對(duì)Connector的限制如下:
項(xiàng)目 | 限制值 |
數(shù)量 | 單實(shí)例最多創(chuàng)建20個(gè)。您可以創(chuàng)建多個(gè)Connector任務(wù)將同一實(shí)例的數(shù)據(jù)導(dǎo)出到不同的服務(wù)中。 |
地域 | 該功能目前有個(gè)別地域未開(kāi)通。具體信息,請(qǐng)參見(jiàn)開(kāi)服地域。 |
跨地域數(shù)據(jù)同步
如果您需要將某個(gè)地域的數(shù)據(jù),通過(guò)Connector同步到另一個(gè)地域的阿里云服務(wù),您需要為該Connector開(kāi)啟公網(wǎng)訪問(wèn),然后在公網(wǎng)進(jìn)行數(shù)據(jù)同步。具體操作步驟,請(qǐng)參見(jiàn)為Connector開(kāi)啟公網(wǎng)訪問(wèn)。
MySQL Source Connector的跨地域數(shù)據(jù)同步比較特殊,需要您自行開(kāi)通企業(yè)網(wǎng)。更多信息,請(qǐng)參見(jiàn)創(chuàng)建MySQL Source Connector。