本文介紹如何使用云消息隊(duì)列 Kafka 版提供的遷移工具將自建Kafka集群的Topic遷移到云消息隊(duì)列 Kafka 版實(shí)例。

前提條件

您已完成以下操作：

操作步驟

  1. 打開(kāi)命令行工具。
  2. 使用cd命令將路徑切換到遷移工具所在目錄。
  3. 執(zhí)行以下命令確認(rèn)要遷移的Topic。
    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 <yourAccessKeyId> --destSk <yourAccessKeySecret> --destRegionId <yourRegionID> --destInstanceId <yourInstanceId> --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í)例名稱。
    4. 在左側(cè)導(dǎo)航欄，單擊Topic 管理。
    5. 在Topic 管理頁(yè)面的Topic列表中，顯示成功遷移的Topic。