迁移集群可用区

更新时间：2026-07-30

该接口用于将集群迁移到指定可用区。迁移前，集群必须已开启统一访问地址。

请求结构

                Java
                
                PUT /v{version}/clusters/{clusterId}/brokers/migration HTTP/1.1
Host: kafka-api.bj.baidubce.com
Authorization: authorization string

请求头域

除公共头域外，无其他特殊头域。

请求参数

参数名称	类型	是否必须	参数位置	描述
version	String	是	URL参数	API版本号
clusterId	String	是	URL参数	集群ID
resizeType	Integer	否	Request Body参数	变配类型。预付费集群取值为 0（升配）、1（降配）或 2（退款）；后付费集群可为空
couponIds	List	否	Request Body参数	使用代金券时，可以指定使用哪些代金券
isAutoPay	Boolean	否	Request Body参数	是否自动扣费，默认为 false
logicalZones	List	是	Request Body参数	迁移后的可用区列表，不可为空，最多包含 3 个可用区
subnets	List	否	Request Body参数	迁移后的子网ID列表，与 logicalZones 一一对应
numberOfBrokerNodes	Integer	是	Request Body参数	迁移后的 Broker 节点总数，最小值为 3
batchSize	Integer	否	Request Body参数	稳定迁移时每批处理的分区数，最小值为 1，必须与 interBrokerThrottle 同时填写；快速迁移时两者均不填写
interBrokerThrottle	Long	否	Request Body参数	稳定迁移时 Broker 间的流量限制，单位为 MB/s，最小值为 1，必须与 batchSize 同时填写；快速迁移时两者均不填写

返回头域

除公共头域外，无其他特殊头域。

返回参数

参数名称	类型	描述
clusterId	String	集群ID
actionId	String	任务ID

错误码

错误码	错误描述	HTTP状态码	描述
ERROR_PARAMS	请求参数错误	400	请求参数错误
CREATE_CLUSTER_ERROR_PARAMETER	创建集群参数错误	400	请求参数不符合要求
CLUSTER_NOT_FOUND	集群不存在	451	集群不存在
CLUSTER_HAD_DELETED	集群已删除	451	集群已删除
CLUSTER_NOT_BELONGED	未拥有该集群	451	当前用户无权操作该集群
CLUSTER_NOT_ACTIVE	集群非运行状态	406	集群非运行状态
CLUSTER_ORDER_BUSY	订单执行中	451	集群存在待生效的订单
CLUSTER_AZ_MIGRATION_UNSUPPORTED	集群不支持可用区变更	451	当前集群或用户不支持迁移可用区
MIGRATE_CLUSTER_AZ_REQUIRES_UNIFIED_ENDPOINT	迁移可用区前需先开启统一访问地址	451	集群未开启统一访问地址
UNSUPPORTED_CLUSTER_OPERATION	不支持的集群操作	451	当前集群模式不支持迁移可用区
UPDATE_CLUSTER_NODE_NUMBER_NOT_CHANGE	节点数量未改变	451	迁移前后的节点分布未发生变化
UPDATE_CLUSTER_NOT_SUPPORT_DECREASE_NODE_COUNT	节点数不支持减少	451	当前用户不支持减少节点数
CLUSTER_EIP_ILLEGAL	EIP实例参数错误	451	EIP数量、状态或规格不符合要求
STOCK_FAILED	库存不足	451	目标可用区库存不足
UPDATE_CLUSTER_FORBIDDEN	集群不可执行更新操作	451	集群不可执行更新操作
UPDATE_CLUSTER_ORDER_FAILED	集群更新下单失败	500	集群更新下单失败
REASSIGN_BATCH_SIZE_INVALID	分批大小设置错误	500	batchSize 设置错误
REASSIGN_INTER_BROKER_THROTTLE_INVALID	流量限制设置错误	500	interBrokerThrottle 设置错误
UPDATE_CLUSTER_FAILED	集群变更失败	500	集群变更失败
INTERNAL_ERROR	服务内部错误	500	服务内部错误

请求示例

                Java
                
            

                PUT http://kafka-api.bj.baidubce.com/v2/clusters/33a168bb70c0459787416077114ab233/brokers/migration
Authorization: bce-auth-v1/ALTAKaiKeDfBD880eMWBE5oIGE/2023-05-08T11:43:45Z/1800/host;x-bce-date/322f3f98ce57d296c0f5abc64e5554b640ea035c5cb462fcaeab54b9810a3c61
Host: kafka-api.bj.baidubce.com

{
    "logicalZones": [
        "cn-bj-a",
        "cn-bj-b",
        "cn-bj-c"
    ],
    "subnets": [
        "sbn-12kruawmu30u",
        "sbn-2abcdemno30u",
        "sbn-3abcdemno30u"
    ],
    "numberOfBrokerNodes": 6,
    "batchSize": 10,
    "interBrokerThrottle": 100,
    "isAutoPay": true,
    "couponIds": [
        "xxxxx"
    ]
}
            

返回示例

                Java
                
            

                HTTP/1.1 200 OK
x-bce-request-id: 97e6d4ad-6fca-4609-ad4d-9a27c4d1a362
Date: Mon, 08 May 2023 09:39:11 GMT
Content-Type: application/json;charset=UTF-8
Server: BWS

{
    "clusterId": "33a168bb70c0459787416077114ab233",
    "actionId": "16411be300de729baaee9b4dc3f0e4cd"
}
            

评价此篇文章

有帮助没帮助

跨VPC访问开关

集群域名开关

百度智能云

消息服务 for Kafka

消息服务 for Kafka

迁移集群可用区

请求结构

请求头域

请求参数

返回头域

返回参数

错误码

请求示例

返回示例