16.4.3. Kafka Connect のアップグレード

この手順では、ホストマシンで Kafka Connect クラスターをアップグレードする方法を説明します。

Kafka Connect はクライアントアプリケーションであり、クライアントをアップグレードするために選択した戦略に含める必要があります。詳細については、クライアントをアップグレードするための戦略 を参照してください。

前提条件

  • Red Hat Enterprise Linux に kafka ユーザーとしてログインしている。

手順

AMQ Streams クラスターの各 Kafka ブローカーに対して、以下を 1 つずつ行います。

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

    注記

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

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

    mkdir /tmp/kafka
unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka

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

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

  4. 一時ディレクトリーから、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/

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

    rm -r /tmp/kafka

  6. スタンドアロンまたは分散モードのいずれかで Kafka Connect を起動します。

    • スタンドアロンモードで起動するには、connect-standalone.sh スクリプトを実行します。Kafka Connect スタンドアロン設定ファイルおよびご使用中の Kafka Connect コネクターの設定ファイルを指定します。 

      su - kafka
/opt/kafka/bin/connect-standalone.sh /opt/kafka/config/connect-standalone.properties connector1.properties
[connector2.properties ...]

    • 分散モードで起動するには、すべての Kafka Connect ノードで /opt/kafka/config/connect-distributed.properties 設定ファイルで Kafka Connect ワーカーを起動します。 

      su - kafka
/opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties

  7. KafkaConnect が実行されていることを確認します。

    • スタンドアロンモードの場合: 

      jcmd | grep ConnectStandalone

    • 分散モードの場合: 

      jcmd | grep ConnectDistributed
  8. Kafka Connect が想定どおりにデータを生成および消費していることを確認します。

関連情報