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: {}

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

   指定 完整模式的 配置示例

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

   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

   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

   1

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

   注意

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

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

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

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

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

4. 创建或更新资源：

   oc apply -f <kafka_rebalance_configuration_file>

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

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

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

   PendingProposal

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

   ProposalReady

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

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

6. 回顾优化方案。

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

   oc describe kafkarebalance <kafka_rebalance_resource_name>

   优化建议示例

   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

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