6.3. Kafka のデプロイ

手順

1. 一時または永続クラスターを作成およびデプロイします。

   • 一時クラスターを作成およびデプロイするには、以下を実行します。

     oc apply -f examples/kafka/kafka-ephemeral.yaml

   • 永続クラスターを作成およびデプロイするには、以下を実行します。

     oc apply -f examples/kafka/kafka-persistent.yaml

2. デプロイメントのステータスを確認します。

   oc get pods -n <my_cluster_operator_namespace>

   Pod 名および readiness が表示される出力

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   my-cluster-kafka-0          1/1     Running   0
   my-cluster-kafka-1          1/1     Running   0
   my-cluster-kafka-2          1/1     Running   0
   my-cluster-zookeeper-0      1/1     Running   0
   my-cluster-zookeeper-1      1/1     Running   0
   my-cluster-zookeeper-2      1/1     Running   0

   my-cluster は Kafka クラスターの名前です。

   デフォルトのデプロイメントでは、Entity Operator クラスター、3 つの Kafka Pod、および 3 つの ZooKeeper Pod をインストールします。

   READY は、Ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されると、デプロイメントは成功しています。

手順

1. Kafka リソースの entityOperator プロパティーを編集し、topicOperator が含まれるようにします。

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. EntityTopicOperatorSpec スキーマ参照に記載されているプロパティーを使用して、Topic Operator の spec を設定します。

   すべてのプロパティーにデフォルト値を使用する場合は、空のオブジェクト ({}) を使用します。

3. リソースを作成または更新します。

   oc apply -f <kafka_configuration_file>

4. デプロイメントのステータスを確認します。

   oc get pods -n <my_cluster_operator_namespace>

   Pod 名と準備状況が表示される出力

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster は Kafka クラスターの名前です。

   READY は、Ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されると、デプロイメントは成功しています。

手順

1. Kafka リソースの entityOperator プロパティーを編集し、userOperator が含まれるようにします。

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. EntityUserOperatorSpec スキーマ参照 に記載されているプロパティーを使用して、User Operator の spec を設定します。

   すべてのプロパティーにデフォルト値を使用する場合は、空のオブジェクト ({}) を使用します。

3. リソースを作成または更新します。

   oc apply -f <kafka_configuration_file>

4. デプロイメントのステータスを確認します。

   oc get pods -n <my_cluster_operator_namespace>

   Pod 名と準備状況が表示される出力

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster は Kafka クラスターの名前です。

   READY は、Ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されると、デプロイメントは成功しています。