2.2. Kafka Connect のデプロイ
Kafka クラスターの設定後、Kafka Connect Source-to-Image(S2I)サービスをデプロイします。このサービスは、Debezium MySQL コネクターを管理するためのフレームワークを提供します。
手順
Kafka Connect Source-to-Image(S2I)サービスをデプロイします。
このコマンドは、単一ノードの Kafka クラスターの YAML ファイルのサンプルを使用して Kafka Connect S2I サービスをデプロイします。
$ oc apply -f examples/kafka-connect/kafka-connect-s2i-single-node-kafka.yaml
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
Debezium MySQL Connector プラグインを使用して、Kafka Connect イメージの新しいビルドを開始します。
このコマンドは、以前にダウンロードした Debezium MySQL Connector プラグインを使用します。
$ oc start-build my-connect-cluster-connect --from-dir ./my-plugins/
ビルドが完了したことを確認します。
このコマンドは、新しいビルドが完了したことを示しています(
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