32.2. ZooKeeper 使用時の Kafka のダウングレード

手順

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

   oc edit kafka <kafka_configuration_file>

2. inter.broker.protocol.version バージョン (および該当する場合は log.message.format.version) を、ダウングレードする Kafka バージョンでサポートされているバージョンに変更します。Kafka.spec.kafka.version は 現在 の Kafka バージョンのままにしておきます。

   たとえば、Kafka 3.9.0 から 3.8.0 にダウングレードする場合:

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

   1

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

   2

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

   1

   Kafka のバージョンは変更されていません。

   2

   ブローカー間プロトコルのバージョンが、以前の Kafka バージョンでサポートされているバージョンに変更されました。

   注記

   log.message.format.version および inter.broker.protocol.version の値は、浮動小数点数として解釈されないように文字列である必要があります。

3. エディターを保存して終了し、ローリング更新の完了を待ちます。

   Pod の状態の遷移を監視して、ローリング更新の進捗を確認します。

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

   ローリング更新により、各 Pod が指定された Kafka ブローカー間プロトコルバージョンを使用していることが保証されます。

4. Kafka.spec.kafka.version を以前のバージョンに変更します。

   たとえば、Kafka 3.9.0 から 3.8.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.8" 

   2

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

   1

   Kafka のバージョンが新しいバージョンに変更されます。

   2

   ブローカー間プロトコルのバージョンは、Kafka バージョンでサポートされています。

5. Kafka バージョンのイメージが Cluster Operator の STRIMZI_KAFKA_IMAGES に定義されているイメージとは異なる場合は、Kafka.spec.kafka.image を更新します。

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

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

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

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

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

8. トピックメタデータの保存に ZooKeeper を使用する 1.7 よりも前のバージョンの Streams for Apache Kafka に戻す場合は、Kafka クラスターから内部トピックストアのトピックを削除します。

   oc run kafka-admin -ti --image=registry.redhat.io/amq-streams/kafka-39-rhel9:2.9.3 --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