第2章 サービスの起動

Debezium を使用するには、AMQ Streams と Debezium コネクターサービスが必要です。このチュートリアルに必要なサービスを起動するには、以下を行う必要があります。

2.1. Kafka クラスターの設定

AMQ Streams を使用して Kafka クラスターを設定します。この手順では、単一ノードの Kafka クラスターをデプロイします。

手順

  1. OpenShift 4.x クラスターで、新しいプロジェクトを作成します。

    $ oc new-project debezium-tutorial
  2. AMQ Streams 1.6 OpenShift インストールとサンプルファイルをダウンロードしたディレクトリーに移動します。
  3. AMQ Streams Cluster Operator をデプロイします。

    Cluster Operator は、OpenShift クラスター内で Kafka クラスターのデプロイおよび管理を行います。このコマンドは、Cluster Operator をデプロイし、作成したプロジェクトのみを監視します。

    $ sed -i 's/namespace: .*/namespace: debezium-tutorial/' install/cluster-operator/*RoleBinding*.yaml
    
    $ oc apply -f install/cluster-operator -n debezium-tutorial
  4. Cluster Operator が稼働していることを確認します。

    このコマンドを実行すると、Cluster Operator は稼働中で、すべての Pod の準備ができていることを確認できます。

    $ oc get pods
    NAME                                       READY   STATUS    RESTARTS   AGE
    strimzi-cluster-operator-5c6d68c54-l4gdz   1/1     Running   0          46s
  5. Kafka クラスターをデプロイします。

    このコマンドは、kafka-ephemeral-single.yaml カスタムリソースを使用して、3 つの ZooKeeper ノードと 1 つの Kafka ノードを持つ Kafka の一時クラスターを作成します。

    $ oc apply -f examples/kafka/kafka-ephemeral-single.yaml
  6. Kafka クラスターが稼働していることを確認します。

    このコマンドを実行すると、Kafka クラスターは稼働中で、すべての Pod の準備ができていることを確認できます。

    $ oc get pods
    NAME                                          READY   STATUS    RESTARTS   AGE
    my-cluster-entity-operator-5b5d4f7c58-8gnq5   3/3     Running   0          41s
    my-cluster-kafka-0                            2/2     Running   0          70s
    my-cluster-zookeeper-0                        2/2     Running   0          107s
    my-cluster-zookeeper-1                        2/2     Running   0          107s
    my-cluster-zookeeper-2                        2/2     Running   0          107s
    strimzi-cluster-operator-5c6d68c54-l4gdz      1/1     Running   0          8m53s