23.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 在给定时间不可用。

要使用 Drain Cleaner 滚动 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 值设置为 0。

您需要监视需要排空的 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 的名称为 <cluster-name>-kafka-<index>，其中 <index> 从 0 开始，最高为副本数量减一。例如，my-cluster-kafka-0。