18.6. 生成优化建议

流程

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

   完整 模式（默认）

   要使用 Kafka 资源中定义的 默认优化目标，请将 spec 属性留空。默认情况下，Cruise Control 以 full 模式重新平衡 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 属性指定 full 模式来运行完整的重新平衡。

   指定 full 模式的配置示例

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

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

   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. （可选）要自动批准优化提议，请将 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

   Copy to Clipboard Toggle word wrap

5. 创建或更新资源：

   oc apply -f <kafka_rebalance_configuration_file>

   Copy to Clipboard Toggle word wrap

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

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

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

   Copy to Clipboard Toggle word wrap

   PendingProposal

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

   ProposalReady

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

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

7. 查看优化方案。

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