17.4.2. Kafka Connect のアップグレード
この手順では、ホストマシンで Kafka Connect クラスターをアップグレードする方法を説明します。
Kafka Connect はクライアントアプリケーションで、クライアントのアップグレードに選択したストラテジーに含める必要があります。詳細は、「クライアントをアップグレードするストラテジー 」を参照してください。
前提条件
-
kafkaユーザーとして Red Hat Enterprise Linux にログインしている。 - Kafka Connect は起動していません。
手順
AMQ Streams クラスターの各 Kafka ブローカーと、1 度に 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
Kafka Connect が稼働していることを確認します。
スタンドアロンモードでは、以下を行います。
jcmd | grep ConnectStandalone
Distributed（分散）:
jcmd | grep ConnectDistributed
- Kafka Connect がデータを想定どおりに生成し、消費していることを確認します。
