第4章 Operator

手順

1. install/cluster-operator/050-Deployment-strimzi-cluster-operator.yaml ファイルを編集し、環境変数 STRIMZI_NAMESPACE で、Cluster Operator がリソースを監視するすべての namespace を一覧表示します。以下に例を示します。

   apiVersion: apps/v1
   kind: Deployment
   spec:
     # ...
     template:
       spec:
         serviceAccountName: strimzi-cluster-operator
         containers:
         - name: strimzi-cluster-operator
           image: registry.redhat.io/amq7/amq-streams-rhel7-operator:1.4.0
           imagePullPolicy: IfNotPresent
           env:
           - name: STRIMZI_NAMESPACE
             value: watched-namespace-1,watched-namespace-2,watched-namespace-3

2. Cluster Operator によって監視されるすべての namespace (上記の例では watched-namespace-1、watched-namespace-2、および watched-namespace-3) に対して、RoleBindings をインストールします。watched-namespace は、直前のステップで使用した namespace に置き換えます。

   oc apply を使用してこれを行うことができます。

   oc apply -f install/cluster-operator/020-RoleBinding-strimzi-cluster-operator.yaml -n watched-namespace
   oc apply -f install/cluster-operator/031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml -n watched-namespace
   oc apply -f install/cluster-operator/032-RoleBinding-strimzi-cluster-operator-topic-operator-delegation.yaml -n watched-namespace

3. Cluster Operator をデプロイします。

   oc apply を使用してこれを行うことができます。

   oc apply -f install/cluster-operator -n my-namespace

手順

1. すべての namespace を監視するように Cluster Operator を設定します。

   1. 050-Deployment-strimzi-cluster-operator.yaml ファイルを編集します。

   2. STRIMZI_NAMESPACE 環境変数の値を * に設定します。

      apiVersion: apps/v1
      kind: Deployment
      spec:
        # ...
        template:
          spec:
            # ...
            serviceAccountName: strimzi-cluster-operator
            containers:
            - name: strimzi-cluster-operator
              image: registry.redhat.io/amq7/amq-streams-rhel7-operator:1.4.0
              imagePullPolicy: IfNotPresent
              env:
              - name: STRIMZI_NAMESPACE
                value: "*"
              # ...

2. クラスター全体ですべての namespace にアクセスできる権限を Cluster Operator に付与する ClusterRoleBindings を作成します。

   oc create clusterrolebinding コマンドを使用します。

   oc create clusterrolebinding strimzi-cluster-operator-namespaced --clusterrole=strimzi-cluster-operator-namespaced --serviceaccount my-namespace:strimzi-cluster-operator
   oc create clusterrolebinding strimzi-cluster-operator-entity-operator-delegation --clusterrole=strimzi-entity-operator --serviceaccount my-namespace:strimzi-cluster-operator
   oc create clusterrolebinding strimzi-cluster-operator-topic-operator-delegation --clusterrole=strimzi-topic-operator --serviceaccount my-namespace:strimzi-cluster-operator

   my-namespace は、Cluster Operator をインストールする namespace に置き換えます。

3. Cluster Operator を OpenShift クラスターにデプロイします。

   oc apply コマンドを使用します。

   oc apply -f install/cluster-operator -n my-namespace

手順

1. Kafka.spec.entityOperator オブジェクトが Kafka リソースに存在することを確認します。このオブジェクトによって Entity Operator が設定されます。

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

2. 「EntityTopicOperatorSpec スキーマ参照」 で説明されたプロパティーを使用して、Topic Operator を設定します。

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

   oc apply を使用します。

   oc apply -f your-file

手順

1. 必要に応じてエディターで Kafka クラスター設定を更新します。

   oc edit を使用します。

   oc edit kafka my-cluster

2. Kafka リソースの spec.entityOperator.topicOperator.resources プロパティーで、Topic Operator のリソース要求および制限を設定します。

   apiVersion: kafka.strimzi.io/v1beta1
   kind: Kafka
   spec:
     # kafka and zookeeper sections...
     entityOperator:
       topicOperator:
         resources:
           request:
             cpu: "1"
             memory: 500Mi
           limit:
             cpu: "1"
             memory: 500Mi

3. 新しい設定を適用してリソースを作成または更新します。

   oc apply を使用します。

   oc apply -f kafka.yaml

手順

1. install/topic-operator/05-Deployment-strimzi-topic-operator.yaml リソースを編集します。以下を変更する必要があります。

   1. Deployment.spec.template.spec.containers[0].env の STRIMZI_KAFKA_BOOTSTRAP_SERVERS 環境変数は、hostname:‍port ペアのカンマ区切りのリストとして、Kafka クラスターのブートストラップブローカーのリストに設定する必要があります。
   2. Deployment.spec.template.spec.containers[0].env の STRIMZI_ZOOKEEPER_CONNECT 環境変数は、hostname:‍port ペアのカンマ区切りのリストとして、ZooKeeper ノードのリストに設定する必要があります。これは、Kafka クラスターが使用する ZooKeeper クラスターと同じである必要があります。
   3. Deployment.spec.template.spec.containers[0].env の STRIMZI_NAMESPACE 環境変数は、Operator によって KafkaTopic リソースが監視される OpenShift namespace に設定する必要があります。

2. Topic Operator をデプロイします。

   oc apply を使用してこれを行うことができます。

   oc apply -f install/topic-operator

3. Topic Operator が正常にデプロイされていることを確認します。oc describe を使用してこれを行うことができます。

   oc describe deployment strimzi-topic-operator

   Replicas: エントリーに 1 available が表示されれば、Topic Operator はデプロイされています。

   注記

   OpenShift への接続が低速な場合やイメージが事前にダウンロードされていない場合は、表示に時間がかかることがあります。

手順

1. Kafka リソースを編集し、希望どおりに User Operator を設定する Kafka.spec.entityOperator.userOperator オブジェクトが含まれるようにします。

2. OpenShift で Kafka リソースを作成または更新します。

   oc apply を使用してこれを行うことができます。

   oc apply -f your-file

手順

1. 必要に応じてエディターで Kafka クラスター設定を更新します。

   oc edit kafka my-cluster

2. Kafka リソースの spec.entityOperator.userOperator.resources プロパティーで、User Operator のリソース要求および制限を設定します。

   apiVersion: kafka.strimzi.io/v1beta1
   kind: Kafka
   spec:
     # kafka and zookeeper sections...
     entityOperator:
       userOperator:
         resources:
           request:
             cpu: "1"
             memory: 500Mi
           limit:
             cpu: "1"
             memory: 500Mi

   ファイルを保存し、エディターを終了します。Cluster Operator によって変更が自動的に適用されます。

手順

1. install/user-operator/05-Deployment-strimzi-user-operator.yaml リソースを編集します。以下を変更する必要があります。

   1. Deployment.spec.template.spec.containers[0].env の STRIMZI_CA_CERT_NAME 環境変数は、TLS クライアント認証に対して新しいユーザー証明書を署名するための認証局の公開鍵が含まれる OpenShift Secret を参照するように設定する必要があります。Secret の ca.crt キーには、認証局の公開鍵が含まれている必要があります。
   2. Deployment.spec.template.spec.containers[0].env の STRIMZI_CA_KEY_NAME 環境変数は、TLS クライアント認証に対して新しいユーザー証明書を署名するための認証局の秘密鍵が含まれる OpenShift Secret を参照するように設定する必要があります。Secret の ca.key キーに、認証局の秘密鍵が含まれている必要があります。
   3. Deployment.spec.template.spec.containers[0].env の STRIMZI_ZOOKEEPER_CONNECT 環境変数は、hostname:‍port ペアのカンマ区切りのリストとして、ZooKeeper ノードのリストに設定する必要があります。これは、Kafka クラスターが使用する ZooKeeper クラスターと同じである必要があります。
   4. Deployment.spec.template.spec.containers[0].env の STRIMZI_NAMESPACE 環境変数は、Operator によって KafkaUser リソースが監視される OpenShift namespace に設定する必要があります。

2. User Operator をデプロイします。

   oc apply を使用してこれを行うことができます。

   oc apply -f install/user-operator

3. User Operator が正常にデプロイされていることを確認します。oc describe を使用してこれを行うことができます。

   oc describe deployment strimzi-user-operator

   Replicas: エントリーに 1 available が表示されれば、User Operator はデプロイされています。

   注記

   OpenShift への接続が低速な場合やイメージが事前にダウンロードされていない場合は、表示に時間がかかることがあります。