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

手順

1. Kafka クラスターをデプロイします。

   1. 『 Installing AMQ Streams and deploying components 』の手順に従って、AMQ Streams operator をインストールします。
   2. 希望の設定を選択し、Kafka Cluster をデプロイし ます。
   3. Kafka Connect s2i をデプロイします。

   これで、Kafka Connect S2I を使用して OpenShift で Kafka クラスターが稼働しました。

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

   $ oc get pods
   
   NAME                                               READY STATUS
   <cluster-name>-entity-operator-7b6b9d4c5f-k7b92    3/3   Running
   <cluster-name>-kafka-0                             2/2   Running
   <cluster-name>-zookeeper-0                         2/2   Running
   <cluster-name>-operator-97cd5cf7b-l58bq            1/1   Running

   Pod の実行の他に、DeploymentConfig が Connect S2I に関連付けられている必要があります。

3. リリース 1.0 を選択し、Red Hat Integration のダウンロードサイト からデータベースの Debezium コネクターアーカイブをダウンロード します。

4. アーカイブを展開して、コネクタープラグインのディレクトリー構造を作成します。

   $ tree ./my-plugin/
   ./my-plugin/
   ├── debezium-connector-mongodb
   |   ├── ...
   ├── debezium-connector-mysql
   │   ├── ...
   ├── debezium-connector-postgres
   │   ├── ...
   └── debezium-connector-sqlserver
       ├── ...

   これで Kafka Connect S2I ビルドがトリガーされます。

5. ビルド設定の名前を確認します。

   $ oc get buildconfigs
   
   NAME                             TYPE     FROM     LATEST
   <cluster-name>-cluster-connect   Source   Binary   2

6. oc start-build コマンドを使用して、Debezium ディレクトリーを使用して Kafka Connect イメージの新しいビルドを開始します。

   oc start-build <cluster-name>-cluster-connect --from-dir ./my-plugin/

   注記

   ビルドの名前は、デプロイされた Kafka Connect クラスターと同じになります。

7. 更新されたデプロイメントが実行していることを確認します。

   oc get pods
   
   NAME                                              READY     STATUS
   <cluster-name>-entity-operator-7b6b9d4c5f-k7b92   3/3       Running
   <cluster-name>-kafka-0                            2/2       Running
   <cluster-name>-zookeeper-0                        2/2       Running
   <cluster-name>-cluster-connect-2-jw695            1/1       Running
   <cluster-name>-cluster-connect-2-deploy           0/1       Completed
   strimzi-cluster-operator-97cd5cf7b-l58bq          1/1       Running

   または、OpenShift Web コンソールの Pods ビューに移動して、Pod が実行中であることを確認できます。