分布式消息服务KAFKA版-Kafka实例开始分区重平衡任务:请求参数

时间:2024-01-24 16:40:31

请求参数

表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时间戳,单位为毫秒

表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列表

support.huaweicloud.com/api-kafka/CreateReassignmentTask.html