10.3. 在短短停机时间的情况下升级 OpenShift

您可以使用 AMQ Streams Drain Cleaner 工具在升级过程中驱除节点。AMQ Streams Drain Cleaner 使用滚动更新 pod 注解注解 pod。这会通知 Cluster Operator 执行被驱除的 pod 的滚动更新。

pod 中断预算只允许指定数量的 pod 在给定时间不可用。在计划维护 Kafka 代理 pod 的过程中，pod 中断预算可确保 Kafka 在高可用性的环境中继续运行。

您可以使用对 Kafka 组件的 模板 自定义来指定 pod 中断预算。默认情况下，pod 中断预算只允许一个 pod 在给定时间不可用。

要做到这一点，您要将 maxUnavailable 设置为 0 ( 零)。减少最大 pod 中断预算为零可防止自愿中断，因此必须手动驱除 pod。

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
  namespace: myproject
spec:
  kafka:
    # ...
    template:
      podDisruptionBudget:
        maxUnavailable: 0
# ...

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
  namespace: myproject
spec:
  kafka:
    # ...
    template:
      podDisruptionBudget:
        maxUnavailable: 0
# ...

在升级过程中，您可以通过 Cluster Operator 手动滚动更新 pod。使用 Pod 资源，滚动使用新 pod 来更新资源 pod。与使用 AMQ Streams Drain Cleaner 一样，对于 pod 中断预算，您需要将 maxUnavailable 值设置为零。

您需要监视需要排空的 pod。然后，添加一个 pod 注解来进行更新。

此处，注解会更新 Kafka 代理。

oc annotate pod <cluster_name>-kafka-<index> strimzi.io/manual-rolling-update=true

oc annotate pod <cluster_name>-kafka-<index> strimzi.io/manual-rolling-update=true

将 & lt;cluster_name > 替换为集群的名称。Kafka 代理 pod 的名称为 & lt;cluster-name&gt; -kafka-<index & gt;，其中 <index> 从零开始，结尾是 replicas减一总数。例如，my-cluster-kafka-0。