本文档介绍在控制台上查看在线迁移命令的操作步骤。
仅支持查看任务对应的在线迁移命令,离线迁移命令请参见离线迁移元数据文档。
在顶部菜单栏中,选择目标 Kafka 实例所在地域,并在左侧菜单栏中选择集群迁移。
在集群迁移页面上的任务列表中,单击目标迁移任务操作列中的查看迁移命令。
在迁移命令对话框内,查看任务对应的在线迁移命令。
在线迁移命令如下:
wget http://kafka-migrate-tool.tos-cn-beijing.volces.com/volc-kafka-migrate.py && python3 volc-kafka-migrate.py --bootstrap-server {您的kafka集群bootstrap servers地址} --access-key {您的账号AK} --secret-key {您的账号SK} --region ${目标 Kafka 实例所在地域} --task-id ${您的迁移任务ID}
在线迁移命令分为 2 部分:
下载迁移工具
在线迁移工具脚本 volc-kafka-migrate.py
。
wget http://kafka-migrate-tool.tos-cn-beijing.volces.com/volc-kafka-migrate.py
在线迁移元数据
python3 volc-kafka-migrate.py --bootstrap-server ${您的kafka集群bootstrap servers地址} --access-key ${您的账号AK} --secret-key ${您的账号SK} --region ${目标Kafka实例所在地域} --task-id ${您的迁移任务ID}
参数 | 说明 |
---|---|
| 源 Kafka 实例的 Bootstrap servers 地址。 |
| 您的火山引擎账号 AK,获取方法参见 API访问密钥管理。 |
| 您的火山引擎账号 SK,获取方法参见 API访问密钥管理。 |
| 目标 Kafka 实例所在地域(Region)的 ID。从控制台上获取的迁移命令自带 Region ID。 |
| 相应迁移任务的 ID,用于在迁移过程中锁定迁移任务。从控制台上获取的迁移命令中自带迁移任务 ID,例如 |