本教程介绍如何使用消息队列Kafka版提供的迁移工具将某个消息队列Kafka版实例的Consumer Group迁移到另一个消息队列Kafka版实例。
前提条件
您已完成以下操作:
注意
- 迁移不会删除源消息队列Kafka版实例的Consumer Group,只是在目标消息队列Kafka版实例创建相同配置的Consumer Group。
- 迁移内容仅为Consumer Group配置,不包含Consumer Group消费的Topic及位点信息。
操作步骤
- 打开命令行工具。
- 使用cd将路径切换到迁移工具所在目录。
- 确认要迁移的Consumer 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]
- 执行以下命令提交要迁移的Consumer Group。
java -jar kafka-migration.jar ConsumerGroupMigrationFromAliyun --sourceAk LTAI4FwQ5aK1mFYCspJ1h***
--sourceSk wvDxjjRQ1tHPiL0oj7Y2Z7WDNkS*** --sourceRegionId cn-hangzhou --sourceInstanceId
alikafka_post-cn-0pp1h0uv6*** --destAk LTAI4FwQ5aK1mFYCspJ1h*** --destSk wvDxjjRQ1tHPiL0oj7Y2Z7***
--destRegionId cn-hangzhou --destInstanceId alikafka_pre-cn-v0h1cng00*** --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
- 确认Consumer Group迁移是否成功。
- 登录消息队列Kafka版控制台。
- 在顶部菜单栏,选择目标实例所在地域。
- 在左侧导航栏,单击Consumer Group管理。
- 在Consumer Group管理页面,选择目标实例。
Consumer Group列表显示成功创建的Consumer Group。
在文档使用中是否遇到以下问题
更多建议
匿名提交