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 值设置为零。

您需要观察需要排空的 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-&lt; index>，其中 <index> 以零开始，结束于副本总数。例如，my-cluster-kafka-0。