7.6. 生成优化方案

流程

1. 创建 KafkaRebalance 资源并指定适当的模式。

   完整 模式（默认）

   要使用 Kafka 资源 中定义的默认优化目标，请将 spec 属性留空。默认情况下，Cruise Control 重新平衡 Kafka 集群以 完全 模式。

   默认有完整重新平衡的配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec: {}

   Copy to Clipboard Toggle word wrap

   您还可以通过 spec.mode 属性指定 完整的 模式，运行完整的重新平衡。

   指定 完整模式的 配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     mode: full

   Copy to Clipboard Toggle word wrap

   add-brokers 模式

   如果要在扩展后重新平衡 Kafka 集群，请指定 add-brokers 模式。

   在这个模式中，现有副本被移到新添加的代理中。您需要指定一个代理作为列表。

   指定 add-brokers 模式的配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     mode: add-brokers
     brokers: [3, 4] 

   1

   Copy to Clipboard Toggle word wrap

   1

   由扩展操作添加的新添加的代理列表。这个属性是必需的。

   remove-brokers 模式

   如果要在缩减前重新平衡 Kafka 集群，请指定 remove-brokers 模式。

   在这个模式中，副本会从要删除的代理中移出。您需要指定要删除的代理作为列表。

   指定 remove-brokers 模式的配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     mode: remove-brokers
     brokers: [3, 4] 

   1

   Copy to Clipboard Toggle word wrap

   1

   要通过缩减操作删除的代理列表。这个属性是必需的。

   注意

   无论使用的重新平衡模式如何，以下步骤以及批准或停止重新平衡的步骤都相同。

2. 要配置 用户提供的优化目标 而不使用默认的目标，请添加 目标 属性并输入一个或多个目标。

   在以下示例中，机架意识和副本容量配置为用户提供的优化目标：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     goals:
       - RackAwareGoal
       - ReplicaCapacityGoal

   Copy to Clipboard Toggle word wrap

3. 要忽略配置的硬目标，请添加 skipHardGoalCheck: true 属性：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaRebalance
   metadata:
     name: my-rebalance
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     goals:
       - RackAwareGoal
       - ReplicaCapacityGoal
     skipHardGoalCheck: true

   Copy to Clipboard Toggle word wrap

4. 创建或更新资源：

   oc apply -f <kafka_rebalance_configuration_file>

   Copy to Clipboard Toggle word wrap

   Cluster Operator 从 Cruise Control 请求优化探测。这可能需要几分钟时间，具体取决于 Kafka 集群的大小。

5. 等待优化提议的状态更改为 ProposalReady ：

   oc get kafkarebalance -o wide -w -n <namespace>

   Copy to Clipboard Toggle word wrap

   PendingProposal

   PendingProposal 状态意味着重新平衡 Operator 正在轮询 Cruise Control API 来检查优化提议是否就绪。

   ProposalReady

   ProposalReady 状态表示优化提议已准备好审核和批准。

   当状态变为 ProposalReady 时，优化提议可以批准。

6. 回顾优化方案。

   优化的提议包含在 KafkaRebalance 资源的 Status.Optimization Result 属性中。

   oc describe kafkarebalance <kafka_rebalance_resource_name>

   Copy to Clipboard Toggle word wrap

   优化建议示例

   Status:
     Conditions:
       Last Transition Time:  2020-05-19T13:50:12.533Z
       Status:                ProposalReady
       Type:                  State
     Observed Generation:     1
     Optimization Result:
       Data To Move MB:  0
       Excluded Brokers For Leadership:
       Excluded Brokers For Replica Move:
       Excluded Topics:
       Intra Broker Data To Move MB:         0
       Monitored Partitions Percentage:      100
       Num Intra Broker Replica Movements:   0
       Num Leader Movements:                 0
       Num Replica Movements:                26
       On Demand Balancedness Score After:   81.8666802863978
       On Demand Balancedness Score Before:  78.01176356230222
       Recent Windows:                       1
     Session Id:                             05539377-ca7b-45ef-b359-e13564f1458c

   Copy to Clipboard Toggle word wrap

   Optimization Result 部分中的属性描述了待处理的集群重新平衡操作。有关每个属性的描述，请参阅 优化提议的内容。