25.7. ZooKeeper 使用時の Kafka のアップグレード

手順

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

   oc edit kafka <kafka_configuration_file>

2. 設定されている場合は、inter.broker.protocol.version および log.message.format.version プロパティーが 現在の バージョンに設定されていることを確認してください。

   たとえば、Kafka バージョン 3.6.0 から 3.7.0 にアップグレードする場合、現在のバージョンは 3.6 です。

   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.6.0
       config:
         log.message.format.version: "3.6"
         inter.broker.protocol.version: "3.6"
         # ...

   log.message.format.version および inter.broker.protocol.version が設定されていない場合、Streams for Apache Kafka では、次のステップでの Kafka バージョンの更新後、これらのバージョンを現在のデフォルトに自動的に更新します。

   注記

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

3. Kafka.spec.kafka.version を変更して、新しい Kafka バージョンを指定します。現在の Kafka バージョンのデフォルトで log.message.format.version および inter.broker.protocol.version のままにします。

   注記

   kafka.version を変更すると、クラスターのすべてのブローカーがアップグレードされ、新しいブローカーバイナリーの使用が開始されます。このプロセスでは、一部のブローカーは古いバイナリーを使用し、他のブローカーはすでに新しいバイナリーにアップグレードされています。inter.broker.protocol.version を現在の設定のままにしておくと、ブローカーはアップグレード中に相互に通信し続けることができます。

   たとえば、Kafka 3.6.0 から 3.7.0 にアップグレードする場合:

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.7.0 1
       config:
         log.message.format.version: "3.6" 2
         inter.broker.protocol.version: "3.6" 3
         # ...

   1

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

   2

   メッセージ形式のバージョンは変更されません。

   3

   ブローカー間のプロトコルバージョンは変更されません。

   警告

   新しい Kafka バージョンの inter.broker.protocol.version が変更された場合は、Kafka をダウングレードできません。ブローカー間プロトコルのバージョンは、__consumer_offsets に書き込まれたメッセージなど、ブローカーによって保存される永続メタデータに使用されるスキーマを判断します。ダウングレードされたクラスターはメッセージを理解しません。

4. Kafka クラスターのイメージが Kafka.spec.kafka.image の Kafka カスタムリソースで定義されている場合、image を更新して、新しい Kafka バージョンでコンテナーイメージを示すようにします。

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

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

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

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

   ローリング更新により、各 Pod が新バージョンの Kafka のブローカーバイナリーを使用するようになります。

6. クライアントのアップグレードに選択したストラテジー に応じて、新バージョンのクライアントバイナリーを使用するようにすべてのクライアントアプリケーションをアップグレードします。

   必要に応じて、Kafka Connect および MirrorMaker の version プロパティーを新バージョンの Kafka として設定します。

   1. Kafka Connect では、KafkaConnect.spec.version を更新します。
   2. MirrorMaker では、KafkaMirrorMaker.spec.version を更新します。

   3. MirrorMaker 2 の場合は、KafkaMirrorMaker2.spec.version を更新します。

      注記

      手動でビルドしたカスタムイメージを使用している場合は、最新の Streams for Apache Kafka ベースイメージを使用してそのイメージを最新の状態にするために、イメージを再ビルドする必要があります。たとえば、Kafka Connect のベースイメージからコンテナーイメージを作成した 場合は、最新のベースイメージとビルド設定を参照するように Dockerfile を更新します。

7. アップグレードされたクライアントアプリケーションが新しい Kafka ブローカーで正しく動作することを確認します。

8. 設定されている場合、新しい inter.broker.protocol.version バージョンを使用するように Kafka リソースを更新します。それ以外の場合は、ステップ 9 に進みます。

   たとえば、Kafka 3.7.0 にアップグレードする場合:

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.7.0
       config:
         log.message.format.version: "3.6"
         inter.broker.protocol.version: "3.7"
         # ...

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

10. 設定されている場合、新しい log.message.format.version バージョンを使用するように Kafka リソースを更新します。それ以外の場合は、ステップ 10 に進みます。

    たとえば、Kafka 3.7.0 にアップグレードする場合:

    apiVersion: kafka.strimzi.io/v1beta2
    kind: Kafka
    spec:
      # ...
      kafka:
        version: 3.7.0
        config:
          log.message.format.version: "3.7"
          inter.broker.protocol.version: "3.7"
          # ...

    重要

    Kafka 3.0.0 以降、inter.broker.protocol.version が 3.0 以上に設定されていると、log.message.format.version オプションは無視されるため、設定する必要はありません。

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

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