第 30 章 降级 Apache Kafka 的流
如果您在升级到 Apache Kafka 的 Streams 版本时遇到问题,您可以将安装恢复到之前的版本。
如果您使用 YAML 安装文件为 Apache Kafka 安装 Streams,您可以使用上一发行版本中的 YAML 安装文件来执行降级过程。您可以通过更新 Cluster Operator 和您使用的 Kafka 版本来降级 Apache Kafka 的 Streams。Kafka 版本降级由 Cluster Operator 执行。
只有在使用安装文件为 Apache Kafka 安装 Streams 时,以下降级指令才适用。如果您使用其他方法(如 OperatorHub )安装 Apache Kafka 的 Streams,则这个方法可能不支持降级,除非在文档中另有指定。为确保成功降级过程,需要使用受支持的方法。
30.1. 将 Cluster Operator 降级到以前的版本 复制链接链接已复制到粘贴板!
如果您在 Apache Kafka 的 Streams 时遇到问题,您可以恢复安装。
此流程描述了如何将 Cluster Operator 部署降级到以前的版本。
先决条件
- 提供了现有 Cluster Operator 部署。
- 您已下载了上一版本的安装文件。
开始前
检查流的 Apache Kafka 功能门 的降级要求。如果永久启用功能门,您可能需要降级到允许您禁用它的版本,然后再降级到目标版本。
流程
记录在之前的 Cluster Operator 安装过程中所做的配置更改。
任何更改都会被 Cluster Operator 的早期版本 覆盖。
- 恢复您的自定义资源,以反映 Apache Kafka 的 Streams 版本支持的配置选项。
更新 Cluster Operator。
根据 Cluster Operator 运行的命名空间修改之前的版本的安装文件。
在 Linux 中,使用:
sed -i 's/namespace: .*/namespace: my-cluster-operator-namespace/' install/cluster-operator/*RoleBinding*.yaml
sed -i 's/namespace: .*/namespace: my-cluster-operator-namespace/' install/cluster-operator/*RoleBinding*.yaml
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 对于 MacOS,使用:
sed -i '' 's/namespace: .*/namespace: my-cluster-operator-namespace/' install/cluster-operator/*RoleBinding*.yaml
sed -i '' 's/namespace: .*/namespace: my-cluster-operator-namespace/' install/cluster-operator/*RoleBinding*.yaml
Copy to Clipboard Copied! Toggle word wrap Toggle overflow -
如果您在现有 Cluster Operator
Deployment
中修改了一个或多个环境变量,请编辑install/cluster-operator/060-Deployment-strimzi-cluster-operator.yaml
文件以使用这些环境变量。
当您有更新的配置时,将其与其余安装资源一起部署:
oc replace -f install/cluster-operator
oc replace -f install/cluster-operator
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 等待滚动更新完成。
获取 Kafka pod 的镜像以确保降级成功:
oc get pod my-cluster-kafka-0 -o jsonpath='{.spec.containers[0].image}'
oc get pod my-cluster-kafka-0 -o jsonpath='{.spec.containers[0].image}'
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 镜像标签显示 Apache Kafka 版本的新 Streams,后跟 Kafka 版本。例如,<
strimzi_version>-kafka-<kafka_version>
。您还可以从
Kafka
资源的状态检查降级是否已成功完成。