11.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. 要配置 用户提供的优化目标 而不使用默认目标，请添加 goals 属性并输入一个或多个目标。

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

   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. （可选）要自动批准优化提议，请将 strimzi.io/rebalance-auto-approval 注解设置为 true ：

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

5. 创建或更新资源：

   oc apply -f <kafka_rebalance_configuration_file>

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

6. 如果您使用自动批准机制，请等待优化提议的状态更改为 Ready。如果您没有启用自动批准机制，请等待优化提议的状态更改为 ProposalReady ：

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

   PendingProposal

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

   ProposalReady

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

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

7. 查看优化提议。

   优化建议包含在 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 部分中的属性描述了待处理的集群重新平衡操作。有关每个属性的描述，请参阅优化提议的内容。