16.5.3. クライアントアプリケーションを新しい Kafka バージョンにアップグレードする

この手順では、クライアントアプリケーションを AMQ Streams 1.5 に使用される Kafka バージョンにアップグレードするための 1 つの可能なアプローチについて説明します。

この手順は、Strategies for upgrade clients で概説されているトピックごとのコンシューマーを最初に、ダウンコンバージョンを使用するアプローチに基づいています。

クライアントアプリケーションには、プロデューサー、コンシューマー、Kafka Connect、Kafka Streams アプリケーション、および MirrorMaker が含まれます。

前提条件

手順

トピックごとに以下を実行します。

  1. コマンドラインで、message.format.version 設定オプションを 2.4 に設定します。 

    bin/kafka-configs.sh --zookeeper <ZooKeeperAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.4
  2. トピックのすべてのコンシューマーとプロデューサーをアップグレードします。
  3. オプションで、Kafka 2.4.0 で追加された Incremental Cooperative Rebalance プロトコルを使用するようにコンシューマーと Kafka Streams アプリケーションをアップグレードするには、以下を参照してください。「コンシューマーおよび Kafka Streams アプリケーションの Cooperative Rebalancing へのアップグレード」 .
  4. アップグレードしたアプリケーションが正しく機能することを確認します。

  5. トピックの message.format.version 設定オプションを 2.5 に変更します。 

    bin/kafka-configs.sh --zookeeper <ZooKeeperAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.5

関連情報