21.5. Kafka コンポーネントのアップグレード
ホストマシン上の Kafka コンポーネントをアップグレードして、最新バージョンの Streams for Apache Kafka を使用します。Streams for Apache Kafka インストールファイルを使用して、次のコンポーネントをアップグレードできます。
- Kafka Connect
- MirrorMaker
- Kafka Bridge (別の ZIP ファイル)
このセットアップでは、Kafka は /opt/kafka/ ディレクトリーにインストールされています。
前提条件
- 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>-kafka-bin.zipファイルの内容を展開します。mkdir /tmp/kafka unzip amq-streams-<version>-kafka-bin.zip -d /tmp/kafkaKafka Bridge の場合は、
amq-streams-<version>-bridge-bin.zipファイルを抽出します。- 実行中の場合は、ホストで実行中の Kafka コンポーネントを停止します。
既存のインストールから
libsおよびbinディレクトリーを削除します。rm -rf ./libs ./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 の起動
./bin/connect-standalone.sh \ ./config/connect-standalone.properties <connector1>.properties [<connector2>.properties ...]分散モードでの Kafka Connect の開始
./bin/connect-distributed.sh \ ./config/connect-distributed.propertiesMirrorMaker 2 を専用モードで起動する
./bin/connect-mirror-maker.sh \ ./config/connect-mirror-maker.propertiesKafka Bridge の起動
./bin/kafka_bridge_run.sh \ --config-file=<path>/application.propertiesKafka コンポーネントが実行中で、期待どおりにデータを生成または消費していることを確認します。
スタンドアロンモードで Kafka Connect が実行されていることを確認する
jcmd | grep ConnectStandalone分散モードの Kafka Connect が実行されていることを確認する
jcmd | grep ConnectDistributedMirrorMaker 2 が専用モードで実行されていることを確認する
jcmd | grep mirrorMakerログをチェックして Kafka Bridge が実行されていることを確認する
HTTP-Kafka Bridge started and listening on port 8080 HTTP-Kafka Bridge bootstrap servers localhost:9092