本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将某个云消息队列 Kafka 版实例的Group迁移到另一个云消息队列 Kafka 版实例。
前提条件
您已完成以下操作:重要
- 迁移不会删除源云消息队列 Kafka 版实例的Group,只是在目标云消息队列 Kafka 版实例创建相同配置的Group。
- 迁移内容仅为Group配置,不包含Group消费的Topic及位点信息。
操作步骤
- 打开命令行工具。
- 使用cd命令将路径切换到迁移工具所在目录。
- 确认要迁移的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]
- 执行以下命令提交要迁移的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
- 确认Group迁移是否成功。
- 登录云消息队列 Kafka 版控制台。
- 在概览页面的资源分布区域,选择地域。
- 在实例列表页面,单击目标实例名称。
- 在左侧导航栏,单击Group 管理。
- 在Group 管理页面的Group列表显示成功迁移的Group。