16.5.5. 新しいメッセージ形式バージョンを使用するための Kafka ブローカーのアップグレード

クライアントアプリケーションがアップグレードされたら、新しいメッセージ形式バージョンを使用するように Kafka ブローカーを更新できます。

AMQ Streams 1.5 に必要な Kafka バージョンを使用するようにクライアントアプリケーションをアップグレードしたときにトピック設定を変更 しなかった 場合、Kafka ブローカーはメッセージを以前のメッセージ形式バージョンに変換するようになり、パフォーマンスが低下する可能性があります。したがって、すべての Kafka ブローカーをできるだけ早く更新して、新しいメッセージ形式のバージョンを使用することが重要です。

注記

Kafka ブローカーを 1 つずつ更新して再起動します。変更したブローカーを再起動する前に、以前に設定して再起動したブローカーを停止します。

前提条件

手順

AMQ Streams クラスターの各 Kafka ブローカーに対して、以下を 1 つずつ行います。

  1. テキストエディターで、更新する Kafka ブローカーのブローカープロパティーファイルを開きます。ブローカープロパティーファイルは、一般的に /opt/kafka/config/ ディレクトリーに保存されます。

  2. log.message.format.version を 2.5 に設定します。 

    log.message.format.version=2.5

  3. コマンドラインで、この手順の一部として最後に変更して再起動した Kafka ブローカーを停止します。この手順で最初の Kafka ブローカーを変更する場合は、ステップ 4 に進みます。 

    /opt/kafka/bin/kafka-server-stop.sh
jcmd | grep kafka

  4. ステップ 2 で設定を変更した Kafka ブローカーを再起動します。 

    /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
  5. 再起動した Kafka ブローカーが、フォローしているパーティションレプリカに追いついたことを確認します。kafka-topics.sh ツールを使用して、ブローカーに含まれるすべてのレプリカが同期していることを確認します。手順は、トピックの一覧表示および説明 を参照してください。