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

手順

1. Kafka クラスターをデプロイします。Kafka クラスターがすでにデプロイされている場合は、以下の 3 つのサブステップを省略します。

   1. AMQ Streams のインストールおよびコンポーネントのデプロイ の手順にしたがって、AMQ Streams operator をインストールします。
   2. 希望の設定を選択し、Kafka Cluster をデプロイ します。
   3. Kafka Connect をデプロイします。

   これで、Kafka Connect を使用して OpenShift で実行されている Kafka クラスターを利用できます。

2. Pod が稼働していることを確認します。Pod 名は AMQ Streams デプロイメントに対応します。

   $ 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 の実行の他に、Kafka Connect に関連付けられた DeploymentConfig が必要です。

3. Red Hat Integration のダウンロードサイト に移動します。
4. データベースの Debezium コネクターアーカイブをダウンロードします。

5. アーカイブを展開して、コネクタープラグインのディレクトリー構造を作成します。複数のアーカイブをダウンロードおよび展開した場合、構造は以下のようになります。

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

6. registry.redhat.io/amq7/amq-streams-kafka-26-rhel7:1.6.0 をベースイメージとして使用して、新規の Dockerfile を作成します。

   FROM registry.redhat.io/amq7/amq-streams-kafka-26-rhel7:1.6.0
   USER root:root
   COPY ./my-plugins/ /opt/kafka/plugins/
   USER 1001

7. コンテナーイメージをビルドします。前の手順で作成した Dockerfile がカレントディレクトリーにある場合は、以下のコマンドのいずれかを入力します。

   podman build -t my-new-container-image:latest .

   docker build -t my-new-container-image:latest .

8. カスタムイメージをコンテナーレジストリーにプッシュします。以下のいずれかのコマンドを実行します。

   podman push my-new-container-image:latest

   docker push my-new-container-image:latest

9. 新しいコンテナーイメージを示します。Debezium コネクターを実行するために作成したイメージの名前を指定するため、以下のいずれかのタスクを実行します。

   • KafkaConnect カスタムリソースの spec.image フィールドを編集します。

     このプロパティーを設定すると、値は Cluster Operator の STRIMZI_DEFAULT_KAFKA_CONNECT_IMAGE 変数を上書きします。以下に例を示します。

     apiVersion: kafka.strimzi.io/v1beta1
     kind: KafkaConnect
     metadata:
       name: my-connect-cluster
       annotations: strimzi.io/use-connector-resources: "true"
     spec:
       #...
       image: my-new-container-image

   • install/cluster-operator/050-Deployment-strimzi-cluster-operator.yaml ファイルの STRIMZI_DEFAULT_KAFKA_CONNECT_IMAGE 変数を編集し、新しいコンテナーイメージを示すようにした後、Cluster Operator を再インストールします。このファイルを編集する場合は、これを OpenShift クラスターに適用する必要があります。

   Kafka Connect デプロイメントによって、新しいイメージの使用が開始されます。