6.2. Kafka ユーザーの設定

手順

1. 作成される KafkaUser が含まれる YAML ファイルを準備します。

   KafkaUser の例

   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaUser
   metadata:
     name: my-user
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     authentication: 

   1

   
       type: tls
     authorization:
       type: simple 

   2

   
       acls:
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Read
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Describe
         - resource:
             type: group
             name: my-group
             patternType: literal
           operation: Read

   Copy to Clipboard Toggle word wrap

   1

   相互 tls または scram-sha-512 として定義されたユーザー認証メカニズム。

   2

   ACL ルールのリストが必要な簡易承認。

2. OpenShift で KafkaUser リソースを作成します。

   oc apply -f <user-config-file>

   Copy to Clipboard Toggle word wrap
3. my-user シークレットからのクレデンシャルをクライアントアプリケーションで使用します。