26.2. KRaft ベースの Kafka クラスターとクライアントアプリケーションのダウングレード

手順

1. Kafka クラスター設定を更新します。

   oc edit kafka <kafka_configuration_file>

2. metadataVersion バージョンを、ダウングレードする Kafka バージョンでサポートされているバージョンに変更します。Kafka.spec.kafka.version は 現在の Kafka バージョンのままにしておきます。

   たとえば、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 を更新します。

   「Kafka バージョンおよびイメージマッピング」を参照してください。

6. Cluster Operator によってクラスターが更新されるまで待ちます。

   Kafka リソースのステータスからダウングレードが正常に完了したことを確認 できます。

7. すべてのクライアントアプリケーション (コンシューマー) をダウングレードして、以前のバージョンのクライアントバイナリーを使用します。

   これで、Kafka クラスターおよびクライアントは以前の Kafka バージョンを使用するようになります。