24.2. Kafka のダウングレード

手順

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

   oc edit kafka KAFKA-CONFIGURATION-FILE

   Copy to Clipboard Toggle word wrap

2. Kafka.spec.kafka.version を変更して、以前のバージョンを指定します。

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

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

   1

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

   2

   
         inter.broker.protocol.version: "3.5" 

   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 を更新します。

   「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. トピックメタデータの保存に ZooKeeper を使用する 1.7 よりも前のバージョンの AMQ Streams に戻す場合は、Kafka クラスターから内部トピックストアのトピックを削除します。

   oc run kafka-admin -ti --image=registry.redhat.io/amq-streams/kafka-36-rhel8:2.6.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