18.4.2. Kafka Connect のアップグレード
この手順では、ホストマシンで Kafka Connect クラスターをアップグレードする方法を説明します。
Kafka Connect はクライアントアプリケーションで、クライアントをアップグレードするために選択したストラテジーに追加する必要があります。詳細は、「 クライアントをアップグレードするストラテジー」を 参照してください。
前提条件
-
Red Hat Enterprise Linux に
kafkaユーザーとしてログインしている。 - Kafka Connect が起動していない。
手順
AMQ Streams クラスターの各 Kafka ブローカーに対して、以下を 1 つずつ行います。
カスタマーポータル から AMQ Streams アーカイブをダウンロードします。
注記プロンプトが表示されたら、Red Hat アカウントにログインします。
コマンドラインで一時ディレクトリーを作成し、
amq-streams-x.y.z-bin.zipファイルの内容を展開します。mkdir /tmp/kafka unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka
実行中の場合は、ホストで実行している Kafka ブローカーおよび ZooKeeper を停止します。
/opt/kafka/bin/kafka-server-stop.sh /opt/kafka/bin/zookeeper-server-stop.sh
既存のインストールから
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
スタンドアロンまたは分散モードのいずれかで 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
KafkaConnect が実行されていることを確認します。
スタンドアロンモードの場合:
jcmd | grep ConnectStandalone
分散モードの場合:
jcmd | grep ConnectDistributed
- Kafka Connect が想定どおりにデータを生成および消費していることを確認します。
