18.4. 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 コンポーネントのインスタンスを実行している各ホストに、以下を行います。

  1. Streams for Apache Kafka または Kafka Bridge のインストールファイルを Streams for Apache Kafka ソフトウェアダウンロードページ からダウンロードします。

    注記

    プロンプトが表示されたら、Red Hat アカウントにログインします。

  2. コマンドラインで一時ディレクトリーを作成し、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 ファイルを抽出します。

  3. 実行中の場合は、ホストで実行中の Kafka コンポーネントを停止します。
  4. 既存のインストールから libs および bin ディレクトリーを削除します。

    rm -rf /opt/kafka/libs /opt/kafka/bin
  5. 一時ディレクトリーから libs および bin ディレクトリーをコピーします。

    cp -r /tmp/kafka/kafka_<version>/libs /opt/kafka/
    cp -r /tmp/kafka/kafka_<version>/bin /opt/kafka/
  6. 必要に応じて、config ディレクトリー内の設定ファイルを更新して、新しいバージョンの変更を反映します。
  7. 一時ディレクトリーを削除します。

    rm -r /tmp/kafka
  8. 適切なスクリプトとプロパティーファイルを使用して 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

  9. 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

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

© 2024 Red Hat, Inc.