2.3. AMQ Streams on RHEL での Debezium のデプロイ

手順

1. Red Hat カスタマーポータルの Red Hat Integration のダウンロードサイト にアクセスし、Debezium コネクターまたは使用するコネクターをダウンロードします。たとえば、Debezium 1.7 MySQL Connector をダウンロードして、Dabezium を MySQL データベースと使用します。

2. /opt/kafka で、他の Kafka Connect プラグインに対してディレクトリーが作成されていない場合は、connector-plugins ディレクトリーを作成します。

   $ sudo mkdir /opt/kafka/connector-plugins

   Copy to Clipboard Toggle word wrap

3. Debezium コネクターアーカイブの内容を /opt/kafka/connector-plugins ディレクトリーに展開します。

   この例では、MySQL コネクターの内容が展開されます。

   $ sudo unzip debezium-connector-mysql-1.7.2.Final.zip -d /opt/kafka/connector-plugins

   Copy to Clipboard Toggle word wrap
4. インストールするコネクターごとに、前述の手順を繰り返します。

5. kafka ユーザーに切り替えます。

   $ su - kafka
   $ Password:

   Copy to Clipboard Toggle word wrap

6. Kafka Connect プロセスが実行中の場合は、停止します。

   1. 次のコマンドを入力して、Kafka Connect が分散モードで実行されているかどうかを確認します。

      $ jcmd | grep ConnectDistributed

      Copy to Clipboard Toggle word wrap

      プロセスが実行中の場合、コマンドはプロセス ID を返します。次に例を示します。

      18514 org.apache.kafka.connect.cli.ConnectDistributed /opt/kafka/config/connect-distributed.properties

      Copy to Clipboard Toggle word wrap

   2. プロセス ID を指定して kill コマンドを入力し、プロセスを停止します。次に例を示します。

      $ kill 18514

      Copy to Clipboard Toggle word wrap

7. /opt/kafka/config/ の connect-distributed.properties ファイルを編集し、Debezium コネクターの場所を指定します。

   plugin.path=/opt/kafka/connector-plugins

   Copy to Clipboard Toggle word wrap

8. 分散モードで Kafka Connect を起動します。

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

   Copy to Clipboard Toggle word wrap

   Kafka Connect が実行されます。起動中に、Debezium コネクターは connector-plugins ディレクトリーからロードされます。

9. 各 Kafka Connect ワーカーノードに対して 6 から 8 を繰り返し行います。