操作步驟

1. 打開命令行工具。

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

3. 執行以下命令，對要遷移的Topic進行預檢。

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

   參數	描述
   sourceZkConnect	自建的源ZooKeeper集群的IP地址
   destAk	目標云消息隊列 Kafka 版實例所屬阿里云賬號的AccessKey ID
   destSk	目標云消息隊列 Kafka 版實例所屬阿里云賬號的AccessKey Secret
   destRegionId	目標云消息隊列 Kafka 版實例的地域ID
   destInstanceId	目標云消息隊列 Kafka 版實例的ID

   待確認的返回結果示例如下：

   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. 執行以下命令，遷移Topic。

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

   參數	描述
   commit	提交遷移

   提交遷移的返回結果示例如下：

   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. 確認Topic遷移是否成功。

   1. 登錄云消息隊列 Kafka 版控制臺。

   2. 在概覽頁面的資源分布區域，選擇地域。

   3. 在實例列表頁面，單擊目標實例名稱。

   4. 在左側導航欄，單擊Topic 管理。

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