第2章 AMQ Streams の使用

手順

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. OpenShift 4 Web コンソールで、Operators > OperatorHub をクリックします。

2. Streaming & Messaging カテゴリーの AMQ Streams Operator を検索または閲覧します。

   
3. AMQ Streams タイルをクリックし、右側のサイドバーで Install をクリックします。

4. Create Operator Subscription 画面で、以下のインストールおよび更新オプションから選択します。

   • Installation Mode: AMQ Streams Operator をクラスターのすべての (プロジェクト) namespace にインストール (デフォルト) するか、特定の (プロジェクト) namespace インストールするかを選択します。namespace を使用して関数を分離することが推奨されます。Kafka クラスターおよび他の AMQ Streams コンポーネントが含まれる namespace とは別に、独自の namespace に Operator をインストールすることが推奨されます。
   • Approval Strategy: デフォルトでは、OLM (Operator Lifecycle Manager) によって、AMQ Streams Operator が自動的に最新の AMQ Streams バージョンにアップグレードされます。今後のアップグレードを手動で承認する場合は、Manual を選択します。詳細は、OpenShift ドキュメントの『Operator』を参照してください。

5. Subscribe をクリックすると、AMQ Streams Operator が OpenShift クラスターにインストールされます。

   AMQ Streams Operator によって、Cluster Operator、CRD、およびロールベースアクセス制御 (RBAC) リソースは選択された namespace またはすべての namespace にデプロイされます。

6. Installed Operators 画面で、インストールの進捗を確認します。AMQ Streams Operator は、ステータスが InstallSucceeded に変更されると使用できます。

   

手順

1. クラスターを開発またはテストの目的で使用する予定である場合は、oc apply を使用して一時クラスターを作成およびデプロイできます。

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

2. クラスターを実稼働で使用する予定である場合は、oc apply を使用して永続クラスターを作成およびデプロイします。

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

手順

1. examples/connector/source-connector.yaml ファイルを編集します。

   apiVersion: kafka.strimzi.io/v1alpha1
   kind: KafkaConnector
   metadata:
     name: my-source-connector 1
     labels:
       strimzi.io/cluster: my-connect-cluster 2
   spec:
     class: org.apache.kafka.connect.file.FileStreamSourceConnector 3
     tasksMax: 2 4
     config: 5
       file: "/opt/kafka/LICENSE"
       topic: my-topic
       # ...

   1

   KafkaConnector リソースの名前を入力します。これは、Kafka Connect 内のコネクターの名前として使用されます。OpenShift リソースで有効な名前を選択します。

   2

   コネクターを作成する Kafka Connect クラスターの名前を入力します。

   3

   コネクタークラスの名前またはエイリアス。これは、Kafka Connect クラスターによって使用されているイメージに存在するはずです。

   4

   コネクターによる作成が可能なタスクの最大数。

   5

   コネクターの設定。使用できる設定オプションは、コネクタークラスによって異なります。

2. OpenShift クラスターに KafkaConnector を作成します。

   oc apply -f examples/connector/source-connector.yaml

3. リソースが作成されたことを確認します。

   oc get kctr --selector strimzi.io/cluster=my-connect-cluster -o name

手順

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

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

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

   oc apply -f your-file

手順

1. OpenShift で strimzi-admin クラスターロールを作成します。

   oc apply を使用します。

   oc apply -f install/strimzi-admin

2. strimzi-admin ClusterRole を OpenShift クラスターの 1 人以上の既存ユーザーに割り当てます。

   oc create を使用します。

   oc create clusterrolebinding strimzi-admin --clusterrole=strimzi-admin --user=user1 --user=user2