26.2. 降级基于 KRaft 的 Kafka 集群和客户端应用程序

流程

1. 更新 Kafka 集群配置。

   oc edit kafka <kafka_configuration_file>

2. 将 metadataVersion 版本改为您要降级的 Kafka 版本支持的 metadataVersion 版本；使 Kafka.spec.kafka.version 保持不变。

   例如，如果从 Kafka 3.7.0 降级到 3.6.0 ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     kafka:
       replicas: 3
       metadataVersion: 3.6-IV2 1
       version: 3.7.0 2
       # ...

   1

   元数据版本被改为早期 Kafka 版本支持的版本。

   2

   Kafka 版本没有改变。

   注意

   metadataVersion 的值必须是字符串，以防止它被解释为浮点数。

3. 保存更改，并等待 Cluster Operator 为 Kafka 资源更新 .status.kafkaMetadataVersion。

4. 将 Kafka.spec.kafka.version 更改为之前的版本。

   例如，如果从 Kafka 3.7.0 降级到 3.6.0 ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     kafka:
       replicas: 3
       metadataVersion: 3.6-IV2 1
       version: 3.6.0 2
       # ...

   1

   Kafka 版本支持元数据版本。

   2

   Kafka 版本已改为新版本。

5. 如果 Kafka 版本的镜像与 Cluster Operator 的 STRIMZI_KAFKA_IMAGES 中定义的镜像不同，请更新 Kafka.spec.kafka.image。

   请参阅 第 25.2.3 节 “Kafka 版本和镜像映射”。

6. 等待 Cluster Operator 更新集群。

   您可以从 Kafka 资源的状态中检查降级是否已成功完成。

7. 降级所有客户端应用程序（使用者）以使用之前的客户端二进制文件版本。

   Kafka 集群和客户端现在使用以前的 Kafka 版本。