15.7. 重新平衡性能调优概述

num.concurrent.partition.movements.per.broker

concurrent_partition_movements_per_broker

5

每个分区重新分配批处理中的最大 inter-broker 分区移动数

num.concurrent.intra.broker.partition.movements

concurrent_intra_broker_partition_movements

2

每个分区重新分配批处理中的最大 intra-broker 分区移动数

num.concurrent.leader.movements

concurrent_leader_movements

1000

每个分区重新分配批处理中的最大分区领导更改数

default.replication.throttle

replication_throttle

null （无限制）

分配给分区重新分配的带宽（每秒字节数）

default.replica.movement.strategies

replica_movement_strategies

BaseReplicaMovementStrategy

用于决定为生成的提议执行分区重新分配命令的顺序（优先级顺序）的列表。有三个策略： PrioritizeSmallReplicaMovementStrategy,PrioritizeLargeReplicaMovementStrategy 和 PostponeUrpReplicaMovementStrategy。对于 server 设置，请使用带有策略类的完全限定名称的列表（将 com.linkedin.kafka.cruisecontrol.executor.strategy. to the each class name 的开始）。对于重新平衡参数，请使用副本移动策略的类名称的逗号分隔列表。