17.4. AMQ Streams 1.8 へのアップグレード

カスタマーポータルから AMQ Streams アーカイブをダウンロードします。

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

mkdir /tmp/kafka
unzip amq-streams-x.y.z-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

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

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

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

cp -r /tmp/kafka/kafka_y.y-x.x.x/libs /opt/kafka/
cp -r /tmp/kafka/kafka_y.y-x.x.x/bin /opt/kafka/
cp -r /tmp/kafka/kafka_y.y-x.x.x/docs /opt/kafka/

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

rm -r /tmp/kafka

inter.broker.protocol.version および log.message.format.version プロパティーが現行バージョンに設定されていることを確認します。

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

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 バージョンのバイナリーの使用を開始します。