18.5. Kafka コンポーネントのアップグレード
ホストマシン上の Kafka コンポーネントをアップグレードして、最新バージョンの Streams for Apache Kafka を使用します。Streams for Apache Kafka インストールファイルを使用して、次のコンポーネントをアップグレードできます。
- Kafka Connect
- MirrorMaker
- Kafka Bridge (別の ZIP ファイル)
前提条件
-
Red Hat Enterprise Linux に
kafka
ユーザーとしてログインしている。 - インストールファイル をダウンロードしている。
Kafka をアップグレード した。
Kafka コンポーネントが Kafka と同じホストで実行されている場合は、アップグレード時に Kafka を停止して起動することも必要です。
手順
Kafka コンポーネントのインスタンスを実行している各ホストに、以下を行います。
Streams for Apache Kafka または Kafka Bridge のインストールファイルを Streams for Apache Kafka ソフトウェアダウンロードページ からダウンロードします。
注記プロンプトが表示されたら、Red Hat アカウントにログインします。
コマンドラインで一時ディレクトリーを作成し、
amq-streams-<version>-bin.zip
ファイルの内容を展開します。mkdir /tmp/kafka unzip amq-streams-<version>-bin.zip -d /tmp/kafka
Kafka Bridge の場合は、
amq-streams-<version>-bridge-bin.zip
ファイルを抽出します。- 実行中の場合は、ホストで実行中の 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/
-
必要に応じて、
config
ディレクトリー内の設定ファイルを更新して、新しいバージョンの変更を反映します。 一時ディレクトリーを削除します。
rm -r /tmp/kafka
適切なスクリプトとプロパティーファイルを使用して Kafka コンポーネントを起動します。
スタンドアロンモードでの Kafka Connect の起動
/opt/kafka/bin/connect-standalone.sh \ /opt/kafka/config/connect-standalone.properties <connector1>.properties [<connector2>.properties ...]
分散モードでの Kafka Connect の開始
/opt/kafka/bin/connect-distributed.sh \ /opt/kafka/config/connect-distributed.properties
MirrorMaker 2 を専用モードで起動する
/opt/kafka/bin/connect-mirror-maker.sh \ /opt/kafka/config/connect-mirror-maker.properties
Kafka Bridge の起動
su - kafka ./bin/kafka_bridge_run.sh \ --config-file=<path>/application.properties
Kafka コンポーネントが実行中で、期待どおりにデータを生成または消費していることを確認します。
スタンドアロンモードで Kafka Connect が実行されていることを確認する
jcmd | grep ConnectStandalone
分散モードの Kafka Connect が実行されていることを確認する
jcmd | grep ConnectDistributed
MirrorMaker 2 が専用モードで実行されていることを確認する
jcmd | grep mirrorMaker
ログをチェックして Kafka Bridge が実行されていることを確認する
HTTP-Kafka Bridge started and listening on port 8080 HTTP-Kafka Bridge bootstrap servers localhost:9092