背景信息
遷移上云可以把源云分布式消息服務Kafka集群的元數據(Topic和Group配置信息)、消息數據和點位信息同步到目標集群,遷移完成后目標集群的元數據與原集群的元數據保持一致,并且支持持續更新和完成后自動停止任務。
使用限制
此功能不收費,會占用當前實例的服務器資源,請結合業務流量和服務器資源占用情況,在合理的情況下進行遷移。
單機版不支持遷移。
計費說明
分布式消息服務Kafka的遷移上云組件處于公測階段,不會在分布式消息服務Kafka側產生費用。同時,天翼云不承諾遷移的SLA,使用遷移上云所依賴的其他產品的SLA和費用說明請以對應產品為準。
環境要求
如果您需要通過遷移上云功能將公網的自建實例的數據同步到分布式消息服務Kafka或者跨地域將某個VPC內的分布式消息服務Kafka的數據同步到另一個VPC的分布式消息服務Kafka,您需要為該實例綁定彈性IP開啟公網訪問,然后在公網上進行數據同步。
如果您需要將某個VPC內的數據通過遷移上云功能同步到另一個VPC的分布式消息服務Kafka,需要手動打通VPC。具體步驟,請參見:使用VPCEP實現跨VPC訪問Kafka
創建遷移任務
登錄分布式消息服務Kafka控制臺。
在左側導航欄,單擊集群遷移,然后單擊遷移上云。
在遷移上云頁簽,單擊創建任務。
在創建遷移上云任務面板,填寫任務名稱,選擇目標實例,然后單擊下一步
填寫接入點,選擇安全協議,任務數,配置信息等,具體請看參數說明。
填寫完參數后,單擊創建,完成任務的創建,在任務列表能看到一條任務,狀態為等待遷移,后臺調度到此任務時,會將任務狀態改為遷移中。
其他操作
查看任務詳情:單擊詳情。在任務詳情頁面,查看遷移上云任務的基礎信息、源服務、目標服務和運行環境配置信息。
查看同步進度:單擊同步進度,選擇查看的Topic,可以看到對應Topic的分區id,最早點位,最新點位和當前點位信息。
啟停任務:單擊停止,然后在提示對話框,單擊確認可停止任務。
參數說明:
| 參數 | 說明 | 示例 |
|---|---|---|
| 接入點 | 源實例的接入點信息 | 192.168.XX.XX:9092 |
| 安全協議 | 選擇源實例的安全協議。支持PLAINTEXT和SASL_PLAINTEXT。 PLAINTEXT:源實例的接入點需為免密接入點 SASL_PLAINTEXT:源實例的接入點需為鑒權接入點 SASL 用戶名:填寫SASL用戶名,需為超級用戶,防止權限不足導致遷移失敗 SASL 密碼:填寫SASL密碼 Sasl_Mechanism:SASL認證機制。可選擇PLAIN、SCRAM-SHA-256和SCRAM-SHA-512。 | PLAINTEXT |
| 任務數 | 選擇同步數據的任務數。取值說明如下:1、6、12 | 1 |
| 遷移完成后自動停止任務 | 遷移任務會自動檢測是否完成遷移 是:在檢測到消息數據完成同步后停止任務 否:不停止任務,您可以手動停止任務 | 否 |
| 同步topic acls | 遷移數據時是否同步Topic ACLS。單擊配置運行環境顯示該參數。默認選擇否。 是:遷移數據時會將源實例的Topic ACLS信息同步到目標實例。若源實例是自建實例,需要您在目標實例重新創建SASL用戶。 否:遷移數據時不會將源實例的Topic ACLS信息同步到目標實例。 | 否 |
| 同步消費組 | 遷移數據時是否將源實例的消費組和對應的點位信息同步創建在目標實例。單擊配置運行環境顯示該參數。默認選擇是。 | 否 |
| Topic | 要遷移的topic信息,選填,多個用半角逗號分開,不填則遷移所有topic | topic1,topic2 |
| Groups | 要遷移的group信息,選填,多個用半角逗號分開,不填則遷移所有group | group1,group2 |
| 副本數是否和源集群保持一致 | 遷移到目標集群的topic的副本數是否和源集群保持一致,默認否 是:副本數是否和源集群保持一致,如原集群topic副本數為1,遷移后的topic副本數也為1 否:遷移后topic的副本數為3 | 否 |