第 149 章 KafkaRebalanceSpec 模式参考

模式

字符串（一个 [remove-brokers, full, add-brokers]）

运行重新平衡的模式。支持的模式是 full, add-brokers, remove-brokers。如果没有指定，则默认使用 full 模式。

代理(Broker)

整数数组

在扩展或要删除的代理时，如果缩减用于重新平衡，则新添加的代理列表。此列表只能用于重新平衡模式 add-brokers 和 removed-brokers。它以 full 模式忽略。

目标

字符串数组

目标列表按优先级降序排列，用于生成和执行重新平衡建议。支持的目标位于 https://github.com/linkedin/cruise-control#goals。如果提供了空目标列表，则使用 default.goals Cruise Control 配置参数中声明的目标。

skipHardGoalCheck

布尔值

是否允许 Kafka CR 中指定的硬目标在优化建议生成中跳过。当其中某些硬目标阻止找到平衡解决方案时，这非常有用。默认值为 false。

rebalanceDisk

布尔值

启用 intra-broker 磁盘平衡，平衡同一代理上磁盘之间的磁盘空间利用率。只适用于使用多个磁盘的 JBOD 存储的 Kafka 部署。启用后，禁用 inter-broker 平衡。默认值为 false。

excludedTopics

string

在计算优化提议时，将排除任何匹配主题的正则表达式。此表达式将由 java.util.regex.Pattern 类解析；有关支持的格式的更多信息，请参阅该类的文档。

concurrentPartitionMovementsPerBroker

整数

持续分区副本移动的上限会进入/移出每个代理。默认值为 5。

concurrentIntraBrokerPartitionMovements

整数

每个代理内磁盘间持续分区副本移动的上限。默认值为 2。

concurrentLeaderMovements

整数

持续分区领导移动的上限。默认值为 1000。

replicationThrottle

整数

用于移动副本的带宽上的上限（以字节/秒为单位）。默认没有限制。

replicaMovementStrategies

字符串数组

用于决定生成的优化方案中副本移动的策略类名称列表。默认情况下，使用 BaseReplicaMovementStrategy，它将按照生成顺序执行副本移动。