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