18.5.3. クライアントアプリケーションの新しい Kafka バージョンへのアップグレード
この手順では、AMQ Streams 1.7 に使用される Kafka バージョンにクライアントアプリケーションをアップグレードする方法の 1 つを説明します。
この手順は、「 クライアントをアップグレードするストラテジー」で説明されている「トピック単位でコンシューマーを最初にアップグレードするため の変換」のアプローチを基にしています。
クライアントアプリケーションには、プロデューサー、コンシューマー、Kafka Connect、Kafka Streams アプリケーション、および MirrorMaker が含まれます。
前提条件
- ZooKeeper バイナリーを更新し、すべての Kafka ブローカーを AMQ Streams 1.7 にアップグレードしている。
- 新しいブローカー間プロトコルバージョンを使用するように Kafka ブローカーが設定されている必要があります。
-
kafkaユーザーとして Red Hat Enterprise Linux にログインしている。
手順
トピックごとに以下を実行します。
コマンドラインで、
message.format.version設定オプションを2.6に設定します。bin/kafka-configs.sh --bootstrap-server <BrokerAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.6
- トピックのコンシューマーおよびプロデューサーをすべてアップグレードします。
- 必要に応じて、コンシューマーおよび Kafka Streams アプリケーションをアップグレードして、Kafka 2.4.0 に追加された 増分 Cooperative Rebalance プロトコルを使用するようにアップグレードするには、「コンシューマーおよび Kafka Streams アプリケーションの Cooperative Rebalancing へのアップグレード」 を参照してください。
- アップグレードしたアプリケーションが正しく機能することを確認します。
トピックの
message.format.version設定オプションを2.7に変更します。bin/kafka-configs.sh --bootstrap-server <BrokerAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.7
