本文导读

展开导读

文档首页/ 分布式消息服务Kafka版/ API参考/ 历史API/ API V2/ 实例管理/ Kafka实例开始分区平衡任务

Kafka实例开始分区平衡任务

更新时间：2025-04-24 GMT+08:00

查看PDF

功能介绍

该接口用于向Kafka实例提交分区平衡任务或计算分区平衡预估时间。

说明：

当前页面API为历史版本API，未来可能停止维护。请使用Kafka实例开始分区平衡任务。

URI

POST /v2/kafka/{project_id}/instances/{instance_id}/reassign

表1 路径参数
参数	是否必选	参数类型	描述
project_id	是	String	项目ID，获取方式请参见获取项目ID。
instance_id	是	String	实例ID。

请求参数

表2 请求Body参数
参数	是否必选	参数类型	描述
reassignments	是	Array of PartitionReassignEntity objects	分区平衡分配方案。
throttle	否	Integer	分区平衡门限值。
is_schedule	否	Boolean	是否作为定时任务执行。若非定时执行，则is_schedule 和execute_at字段可为空；若为定时执行，is_schedule为true，execute_at字段非空。
execute_at	否	Long	定时时间，格式为Unix时间戳，单位为毫秒
time_estimate	否	Boolean	设为true表示执行时间预估任务，false为执行分区平衡任务。

表3 PartitionReassignEntity
参数	是否必选	参数类型	描述
topic	是	String	topic名称
brokers	否	Array of integers	分区平衡到的broker列表，自动生成分配方案时需指定该参数。
replication_factor	否	Integer	副本因子，自动生成分配方案时可指定。
assignment	否	Array of TopicAssignment objects	手动指定的分配方案。brokers参数与该参数不能同时为空。

表4 TopicAssignment
参数	是否必选	参数类型	描述
partition	否	Integer	手动指定分配方案时的分区号。
partition_brokers	否	Array of integers	手动指定某个分区将要分配的broker列表

响应参数

状态码： 200

表5 响应Body参数
参数	参数类型	描述
job_id	String	任务ID（当执行分区平衡任务时仅返回job_id）。
reassignment_time	Integer	预估时间，单位为秒（当执行预估时间任务时仅返回reassignment_time）。

请求示例

POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/reassign

{
  "reassignments" : [ {
    "topic" : "topic-1513476102",
    "brokers" : [ 0, 1, 2 ],
    "replication_factor" : 3,
    "assignment" : [ {
      "partition" : 0,
      "partition_brokers" : [ 0, 1, 2 ]
    }, {
      "partition" : 1,
      "partition_brokers" : [ 1, 2, 0 ]
    }, {
      "partition" : 2,
      "partition_brokers" : [ 2, 0, 1 ]
    } ]
  }, {
    "topic" : "topic-1513558717",
    "brokers" : [ 0, 1, 4 ],
    "replication_factor" : 3,
    "assignment" : [ {
      "partition" : 0,
      "partition_brokers" : [ 0, 1, 2 ]
    }, {
      "partition" : 1,
      "partition_brokers" : [ 1, 2, 0 ]
    }, {
      "partition" : 2,
      "partition_brokers" : [ 2, 0, 1 ]
    } ]
  } ],
  "throttle" : 10000000,
  "time_estimate" : false
}

响应示例

状态码： 200

提交分区平衡任务成功（若为预估时间任务则返回预估时间）。

{
  "job_id" : "8a2c259182ab0e9d0182ab1882560009",
  "reassignment_time" : 10
}

状态码


状态码	描述
200	提交分区平衡任务成功（若为预估时间任务则返回预估时间）。

错误码

请参见错误码。

父主题：实例管理

上一篇：新增Kafka实例指定Topic分区

下一篇：消费组管理

意见反馈

文档内容是否对您有帮助？

有帮助没帮助

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！您可在我的云声建议查看反馈及问题处理状态。

系统繁忙，请稍后重试

在使用文档中是否遇到以下问题

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消

如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨

盘古Doer提问云社区提问