9.2. 降级 Kafka

Kafka 降级依赖于兼容的当前和目标 Kafka 版本，以及记录消息的状态。

如果该版本不支持集群中 曾使用的任何 inter.broker.protocol.version 设置，或者已将消息添加到使用 较新的 log.message.format.version 的消息日志中，则无法恢复到以前的 Kafka 版本。

inter.broker.protocol.version 决定代理用于存储持久元数据的模式，例如写入到 __consumer_offsets 的消息的 schema。如果您降级到不理解之前在集群中使用的 inter.broker.protocol.version 的 Kafka 版本，代理会遇到它无法理解的数据。

如果 Kafka 的目标降级版本有：

如果新版本曾使用过上一版本不支持 的 log.message.format.version，则无法进行降级，包括当使用了 log.message.format.version 的默认值时。例如，这个资源可以降级为 Kafka 版本 2.7.0，因为 log.message.format.version 尚未更改：

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
spec:
  # ...
  kafka:
    version: 2.8.0
    config:
      log.message.format.version: "2.7"
      # ...

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
spec:
  # ...
  kafka:
    version: 2.8.0
    config:
      log.message.format.version: "2.7"
      # ...

如果 log.message.format.version 设置为 "2.8" 或没有值（因此该参数使用 2.8.0 代理 2.8 的默认值），则无法进行降级。