ApsaraMQ for Kafka：Confluent叢集遷移教程

遷移操作

LDAP遷移

登入阿里雲Confluent叢集控制台，將帳號密碼資訊更新到新的叢集上。

1. 登入雲訊息佇列 Kafka 版控制台，在左側導覽列，單擊实例列表。

2. 在实例列表頁面，單擊目標執行個體名稱。

3. 在实例详情頁面，單擊左側操作欄的使用者管理，然後單擊添加LDAP使用者。

4. 在添加LDAP使用者對話方塊，設定使用者名稱稱、密碼並確認密碼，單擊確認。

5. 登入Control Center，詳情請參見登入Control Center。

6. 在右側功能表列選擇 > MANAGE ROLE ASSIGNMENTS，然後單擊Assignments，選擇目標新叢集。

7. 在叢集詳情頁面，單擊右側Add role assignment，將LDAP許可權資訊更新到新的叢集上。

資料移轉

1. 在新的叢集中建立舊叢集對應的Topic。詳情請參見建立Topic。

2. 修改生產者的存取點，將生產者轉移到新的叢集上。

3. 等待消費者在舊的叢集上消費完成，修改消費者的存取點，將消費者轉移到新的叢集上。

4. 下線舊叢集。

Schema遷移

在新的叢集中建立Topic後，可以自行在Topic上建立Schema。

資料移轉

LDAP遷移

阿里雲將通過提供Curl命令的方式輔助您進行遷移。

1. 登入雲訊息佇列 Kafka 版控制台，將LDAP使用者帳號密碼資訊添加至新叢集中，詳情請參見新增使用者。

2. 阿里雲向您提供相關Curl命令以拉取您的LDAP許可權資訊。

3. 您將LDAP許可權資訊發送給阿里雲支援人員。

4. 執行阿里雲提供的Curl命令，將許可權資訊更新到新的Confluent叢集上。

   樣本如下：

   curl -i -X POST \
      -H "Authorization:Basic XXXX==" \
      -H "Content-Type:application/json" \
      -d \
   '{"clusters":{"kafka-cluster":"XXXX"},"path":[]}' \
    'https://mds-XXXX.csp.aliyuncs.com/security/1.0/lookup/managed/rolebindings/principal/User:root'

通過ClusterLink遷移資料

Confluent提供了ClusterLink這一遷移工具，能夠無損地將Topic從一個Cluster遷移到另一個Cluster上。 ClusterLink運行在Kafka Broker上，通過建立Mirror Topic的方式，使用Consumer去消費源叢集的資料。等到新的Topic跟上了舊叢集的Topic，即可遷移生產者和消費者到新的叢集，並將其狀態從同步中改為正常狀態，即完成了同步。

1. 阿里雲支援人員建立Clusterlink任務，並且設定需要同步的Mirror Topic。Clusterlink開啟遷移後，等待Mirror的Lag靠近0。

2. 您停止源Topic的訊息生產，待消費者消費完剩餘資料後再停止消費者。

   說明

   如果這裡有微服務同事進行生產和消費，那麼需要再停止生產者時停止這樣的微服務。

3. 當Mirror Lag為0時，阿里雲支援人員將Mirror Topic的狀態設定為PROMOTE，成為正式的Topic意味著這個Topic可以在Destination Cluster上進行生產。

4. 將所有的消費者和生產者都移動到新的叢集上。當資料已經完成遷移，阿里雲支援人員會修改網域名稱解析，將網域名稱重新導向到新的叢集。

5. 您重新啟動生產者和消費者，就可以完成消費者和生產者從舊叢集到新叢集的轉移。

6. 檢查遷移後的Topic是否能正常工作。

通過SchemaLink遷移Schema

您將需要通過SchemaLink遷移的Topic提供給阿里雲支援人員，阿里雲側建立SchemaLink，將源叢集的Schema資訊同步到目的地組群的Schema上。這裡需要保證在遷移過程中，不要建立新的Schema或者對Topic進行變動。