操作步驟

1. 打開(kāi)命令行工具。

2. 使用cd命令將路徑切換到遷移工具所在目錄。

3. 執(zhí)行以下命令，對(duì)要遷移的Topic進(jìn)行預(yù)檢。

   java -jar kafka-migration-assessment.jar TopicMigrationFromZk  \ 
   --sourceZkConnect 192.168.XX.XX  \ 
   --destAk <yourdestAccessKeyId>  \ 
   --destSk <yourdestAccessKeySecret>  \ 
   --destRegionId <yourdestRegionId>  \ 
   --destInstanceId <yourdestInstanceId>

   參數(shù)	描述
   sourceZkConnect	自建的源ZooKeeper集群的IP地址
   destAk	目標(biāo)云消息隊(duì)列 Kafka 版實(shí)例所屬阿里云賬號(hào)的AccessKey ID
   destSk	目標(biāo)云消息隊(duì)列 Kafka 版實(shí)例所屬阿里云賬號(hào)的AccessKey Secret
   destRegionId	目標(biāo)云消息隊(duì)列 Kafka 版實(shí)例的地域ID
   destInstanceId	目標(biāo)云消息隊(duì)列 Kafka 版實(shí)例的ID

   待確認(rèn)的返回結(jié)果示例如下：

   13:40:08 INFO - Begin to migrate topics:[test]
   13:40:08 INFO - Total topic number:1
   13:40:08 INFO - Will create topic:test, isCompactTopic:false, partition number:1

4. 執(zhí)行以下命令，遷移Topic。

   java -jar kafka-migration-assessment.jar TopicMigrationFromZk  \ 
   --sourceZkConnect 192.168.XX.XX  \ 
   --destAk <yourdestAccessKeyId>  \ 
   --destSk <yourdestAccessKeySecret>  \ 
   --destRegionId <yourdestRegionId>  \ 
   --destInstanceId <yourdestInstanceId>  \
   --commit

   參數(shù)	描述
   commit	提交遷移

   提交遷移的返回結(jié)果示例如下：

   13:51:12 INFO - Begin to migrate topics:[test]
   13:51:12 INFO - Total topic number:1
   13:51:13 INFO - cmd=TopicMigrationFromZk, request=null, response={"code":200,"requestId":"7F76C7D7-AAB5-4E29-B49B-CD6F1E0F508B","success":true,"message":"operation success"}
   13:51:13 INFO - TopicCreate success, topic=test, partition number=1, isCompactTopic=false

5. 確認(rèn)Topic遷移是否成功。

   1. 登錄云消息隊(duì)列 Kafka 版控制臺(tái)。

   2. 在概覽頁(yè)面的資源分布區(qū)域，選擇地域。

   3. 在實(shí)例列表頁(yè)面，單擊目標(biāo)實(shí)例名稱(chēng)。

   4. 在左側(cè)導(dǎo)航欄，單擊Topic 管理。

   5. 在Topic 管理頁(yè)面的Topic列表中，顯示成功遷移的Topic。