9.2.2. 降级 Kafka 代理和客户端应用程序

流程

1. 更新 Kafka 集群配置。

   oc edit kafka KAFKA-CONFIGURATION-FILE

   Copy to Clipboard Toggle word wrap

2. 更改 Kafka.spec.kafka.version 以指定上一版本。

   例如，如果从 Kafka 2.8.0 降级到 2.7.0：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # ...
     kafka:
       version: 2.7.0 

   1

   
       config:
         log.message.format.version: "2.7" 

   2

   
         inter.broker.protocol.version: "2.7" 

   3

   
         # ...

   Copy to Clipboard Toggle word wrap

   1

   Kafka 版本已改为以前的版本。

   2

   消息格式版本保持不变。

   3

   代理协议版本没有改变。

   注意

   您必须将 log.message.format.version 和 inter.broker.protocol.version 的值格式化为字符串，以防止将其解释为浮动点数。

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

   请查看 第 8.4.3 节 “Kafka 版本和镜像映射”

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

   检查日志中的更新，或者查看 pod 状态转换：

   oc logs -f CLUSTER-OPERATOR-POD-NAME | grep -E "Kafka version downgrade from [0-9.]+ to [0-9.]+, phase ([0-9]+) of \1 completed"

   Copy to Clipboard Toggle word wrap

   oc get pod -w

   Copy to Clipboard Toggle word wrap

   检查 Cluster Operator 日志中的 INFO 级别信息：

   Reconciliation #NUM(watch) Kafka(NAMESPACE/NAME): Kafka version downgrade from FROM-VERSION to TO-VERSION, phase 1 of 1 completed

   Copy to Clipboard Toggle word wrap

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

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

6. 如果您要恢复到早于 0.22 的 AMQ Streams 版本（使用 ZooKeeper 存储主题），请从 Kafka 集群中删除内部主题存储主题。

   oc run kafka-admin -ti --image=registry.redhat.io/amq7/amq-streams-kafka-28-rhel7:1.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