30.3. 使用 ZooKeeper 时降级 Kafka

流程

1. 更新 Kafka 集群配置。

   oc edit kafka <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

2. 将 inter.broker.protocol.version 版本（和 log.message.format.version ）改为您降级的 Kafka 版本支持的版本；将 Kafka.spec.kafka.version 保持不变。

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

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     # ...
     kafka:
       version: 3.8.0 

   1

   
       config:
         inter.broker.protocol.version: "3.7" 

   2

   
         log.message.format.version: "3.7"
         # ...

   Copy to Clipboard Toggle word wrap

   1

   Kafka 版本没有改变。

   2

   inter-broker 协议版本被改为早期 Kafka 版本支持的版本。

   注意

   log.message.format.version 和 inter.broker.protocol.version 的值必须是字符串，以防止它们被解释为浮点号。

3. 保存并退出编辑器，然后等待滚动更新完成。

   通过观察 pod 状态转换来检查滚动更新的进度：

   oc get pods my-cluster-kafka-0 -o jsonpath='{.spec.containers[0].image}'

   Copy to Clipboard Toggle word wrap

   滚动更新可确保每个 pod 使用指定的 Kafka inter-broker 协议版本。

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

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

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     # ...
     kafka:
       version: 3.7.0 

   1

   
       config:
         inter.broker.protocol.version: "3.7" 

   2

   
         log.message.format.version: "3.7"
         # ...

   Copy to Clipboard Toggle word wrap

   1

   Kafka 版本已改为新版本。

   2

   Kafka 版本支持 inter-broker 协议版本。

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

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

6. 等待 Cluster Operator 更新集群。

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

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

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

8. 如果您要恢复到之前早于 1.7 的 Apache Kafka 的 Streams 版本，它使用 ZooKeeper 进行主题元数据存储，请从 Kafka 集群中删除内部主题存储主题。

   oc run kafka-admin -ti --image=registry.redhat.io/amq-streams/kafka-38-rhel9:2.8.0 --rm=true --restart=Never -- ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic __strimzi-topic-operator-kstreams-topic-store-changelog --delete && ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic __strimzi_store_topic --delete

   Copy to Clipboard Toggle word wrap