第2章 サービスの起動
Debezium を使用するには、AMQ Streams と Debezium コネクターサービスが必要です。このチュートリアルに必要なサービスを起動するには、以下を行う必要があります。
2.1. Kafka クラスターの設定
AMQ Streams を使用して Kafka クラスターを設定します。この手順では、単一ノードの Kafka クラスターをデプロイします。
手順
OpenShift 4.x クラスターで、新しいプロジェクトを作成します。
$ oc new-project cdc-tutorial
- AMQ Streams 1.4 OpenShift インストールとサンプルファイルをダウンロードしたディレクトリーに移動します。
AMQ Streams Cluster Operator をデプロイします。
Cluster Operator は、OpenShift クラスター内で Kafka クラスターのデプロイおよび管理を行います。このコマンドは、Cluster Operator をデプロイし、作成したプロジェクトのみを監視します。
$ sed -i 's/namespace: .*/namespace: cdc-tutorial/' install/cluster-operator/*RoleBinding*.yaml $ oc apply -f install/cluster-operator -n cdc-tutorial
Cluster Operator が稼働していることを確認します。
このコマンドを実行すると、Cluster Operator は稼働中で、すべての Pod の準備ができていることを確認できます。
$ oc get pods NAME READY STATUS RESTARTS AGE strimzi-cluster-operator-5c6d68c54-l4gdz 1/1 Running 0 46s
Kafka クラスターをデプロイします。
このコマンドは、
kafka-ephemeral-single.yaml
カスタムリソースを使用して、3 つの ZooKeeper ノードと 1 つの Kafka ノードを持つ Kafka の一時クラスターを作成します。$ oc apply -f examples/kafka/kafka-ephemeral-single.yaml
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