2.2. Kafka Connect のデプロイ

手順

1. Kafka Connect Source-to-Image(S2I)サービスをデプロイします。

   このコマンドは、単一ノードの Kafka クラスターの YAML ファイルのサンプルを使用して Kafka Connect S2I サービスをデプロイします。

   $ oc apply -f examples/kafka-connect/kafka-connect-s2i-single-node-kafka.yaml

2. Kafka Connect サービスが実行していることを確認します。

   このコマンドを実行すると、Kafka Connect サービスが稼働中で、Pod の準備ができていることを確認できます。

   $ oc get pods -l strimzi.io/name=my-connect-cluster-connect
   NAME                                          READY   STATUS      RESTARTS   AGE
   my-connect-cluster-connect-1-dxcs9            1/1     Running     0          7m

3. Debezium MySQL Connector プラグインを使用して、Kafka Connect イメージの新しいビルドを開始します。

   このコマンドは、以前にダウンロードした Debezium MySQL Connector プラグインを使用します。

   $ oc start-build my-connect-cluster-connect --from-dir ./my-plugins/

4. ビルドが完了したことを確認します。

   このコマンドは、新しいビルドが完了したことを示しています(my-connect-cluster-connect-2)。Debezium MySQL Connector がインストールされている。

   $ oc get build
   NAME                           TYPE     FROM     STATUS     STARTED         DURATION
   my-connect-cluster-connect-1   Source            Complete   9 minutes ago   2m10s
   my-connect-cluster-connect-2   Source   Binary   Complete   4 minutes ago   2m2s