19.4. Kafka ブローカーおよび ZooKeeper のアップグレード

AMQStreams ソフトウェアのダウンロードページ から AMQStreams アーカイブをダウンロードします。

コマンドラインで一時ディレクトリーを作成し、amq-streams-<version>-bin.zip ファイルの内容を展開します。

mkdir /tmp/kafka
unzip amq-streams-<version>-bin.zip -d /tmp/kafka

実行中の場合は、ホストで実行している ZooKeeper および Kafka ブローカーを停止します。

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

マルチノードクラスターで Kafka を実行している場合は、「Kafka ブローカーの正常なローリング再起動の実行」 を参照してください。

既存のインストールから libs および bin ディレクトリーを削除します。

rm -rf /opt/kafka/libs /opt/kafka/bin

一時ディレクトリーから libs および bin ディレクトリーをコピーします。

cp -r /tmp/kafka/kafka_<version>/libs /opt/kafka/
cp -r /tmp/kafka/kafka_<version>/bin /opt/kafka/

一時ディレクトリーを削除します。

rm -r /tmp/kafka

/opt/kafka/config/server.properties プロパティーファイルを編集します。

inter.broker.protocol.version および log.message.format.version プロパティーを 現在の バージョンに設定します。

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

inter.broker.protocol.version=3.4
log.message.format.version=3.4

アップグレード元の Kafka バージョンに応じた正しいバージョン (3.3、3.4 など) を使用してください。inter.broker.protocol.version を現在の設定のままにしておくと、ブローカーはアップグレード中に相互に通信し続けることができます。

プロパティーが設定されていない場合は、現在のバージョンでプロパティーを追加します。

Kafka 3.0.0 以降からアップグレードする場合は、inter.broker.protocol.version を設定するだけで済みます。

更新された ZooKeeper および Kafka ブローカーを再起動します。

/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

Kafka ブローカーと ZooKeeper は、最新の Kafka バージョンのバイナリーの使用を開始します。

マルチノードクラスターでブローカーを再起動する方法は、「Kafka ブローカーの正常なローリング再起動の実行」 を参照してください。

再起動した Kafka ブローカーが、フォローしているパーティションレプリカに追いついたことを確認します。

kafka-topics.sh ツールを使用して、ブローカーに含まれるすべてのレプリカが同期していることを確認します。手順は、トピックの一覧表示および説明 を参照してください。

次の手順では、新しい inter-broker プロトコルバージョンを使用するように Kafka ブローカーを更新します。

各ブローカーを一度に 1 つずつ更新します。

/opt/kafka/config/server.properties ファイルで inter.broker.protocol.version プロパティーを 3.5 に設定します。

inter.broker.protocol.version=3.5

コマンドラインで、変更した Kafka ブローカーを停止します。

/opt/kafka/bin/kafka-server-stop.sh

Kafka が実行されていないことを確認します。

jcmd | grep kafka

変更した Kafka ブローカーを再起動します。

/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

Kafka が稼働していることを確認します。

jcmd | grep kafka

Kafka 3.0.0 より前のバージョンからアップグレードする場合は、/opt/kafka/config/server.properties ファイルで log.message.format.version プロパティーを 3.5 に設定します。

log.message.format.version=3.5

コマンドラインで、変更した Kafka ブローカーを停止します。

/opt/kafka/bin/kafka-server-stop.sh

Kafka が実行されていないことを確認します。

jcmd | grep kafka

変更した Kafka ブローカーを再起動します。

/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

Kafka が稼働していることを確認します。

jcmd | grep kafka

再起動した Kafka ブローカーが、フォローしているパーティションレプリカに追いついたことを確認します。

kafka-topics.sh ツールを使用して、ブローカーに含まれるすべてのレプリカが同期していることを確認します。手順は、トピックの一覧表示および説明 を参照してください。