本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将某个云消息队列 Kafka 版实例的Group迁移到另一个云消息队列 Kafka 版实例。

前提条件

您已完成以下操作:
重要
  • 迁移不会删除源云消息队列 Kafka 版实例的Group,只是在目标云消息队列 Kafka 版实例创建相同配置的Group
  • 迁移内容仅为Group配置,不包含Group消费的Topic及位点信息。

操作步骤

  1. 打开命令行工具。
  2. 使用cd命令将路径切换到迁移工具所在目录。
  3. 确认要迁移的Group
    java -jar kafka-migration.jar ConsumerGroupMigrationFromAliyun --sourceAk <yoursourceAccessKeyId> --sourceSk <yoursourceAccessKeySecret> --sourceRegionId <yoursourceRegionId> --sourceInstanceId <yoursourceInstanceId> --destAk <yourdestAccessKeyId> --destSk <yourdestAccessKeySecret> --destRegionId <yourdestRegionId> --destInstanceId <yourdestInstanceId>
    参数描述
    sourceAk云消息队列 Kafka 版实例所属阿里云账号的AccessKey ID
    sourceSk云消息队列 Kafka 版实例所属阿里云账号的AccessKey Secret
    sourceRegionId云消息队列 Kafka 版实例的地域ID
    sourceInstanceId云消息队列 Kafka 版实例的ID
    destAk目标云消息队列 Kafka 版实例所属阿里云账号的AccessKey ID
    destSk目标云消息队列 Kafka 版实例所属阿里云账号的AccessKey Secret
    destRegionId目标云消息队列 Kafka 版实例的地域ID
    destInstanceId目标云消息队列 Kafka 版实例的ID
    待确认的返回结果示例如下:
    10:54:26 INFO - cmd=ConsumerGroupMigrationFromAliyun, request=null, response={"code":200,"requestId":"9793DADB-55A5-4D4E-9E9C-D4DA8B35370C","success":true,"consumerList":[{"instanceId":"alikafka_post-cn-0pp1h0uv6***","regionId":"cn-hangzhou","consumerId":"Demo","tags":[{"value":"","key":"migration"}]}],"message":"operation success."}
    10:54:26 INFO - Will create consumer groups:[Demo]
  4. 执行以下命令提交要迁移的Group
    java -jar kafka-migration.jar ConsumerGroupMigrationFromAliyun --sourceAk LTAI4FwQ5aK1mFYCspJ1**** --sourceSk wvDxjjRQ1tHPiL0oj7Y2Z7WDNk**** --sourceRegionId cn-hangzhou --sourceInstanceId alikafka_post-cn-0pp1h0uv**** --destAk LTAI4FwQ5aK1mFYCspJ1**** --destSk wvDxjjRQ1tHPiL0oj7Y2Z**** --destRegionId cn-hangzhou --destInstanceId alikafka_pre-cn-v0h1cng0**** --commit
    参数说明
    commit提交迁移
    提交迁移的返回结果示例如下:
    10:54:40 INFO - cmd=ConsumerGroupMigrationFromAliyun, request=null, response={"code":200,"requestId":"49E53B79-3C2C-4BCF-8BC8-07B0BB14B52A","success":true,"consumerList":[{"instanceId":"alikafka_post-cn-0pp1h0uv6***","regionId":"cn-hangzhou","consumerId":"Demo","tags":[{"value":"","key":"migration"}]}],"message":"operation success."}
    10:54:41 INFO - cmd=ConsumerGroupMigrationFromAliyun, request=null, response={"code":200,"requestId":"5AEEFB13-2A6B-4265-97CB-902CFA483339","success":true,"message":"operation success"}
    10:54:41 INFO - ConsumerCreate success, consumer group=Demo
  5. 确认Group迁移是否成功。
    1. 登录云消息队列 Kafka 版控制台
    2. 概览页面的资源分布区域,选择地域。
    3. 实例列表页面,单击目标实例名称。
    4. 在左侧导航栏,单击Group 管理
    5. Group 管理页面的Group列表显示成功迁移的Group。