6.4. User Operator 사용

절차

1. KafkaUser 리소스를 구성합니다.

   이 예제에서는 ACL을 사용하여 TLS 인증 및 간단한 권한 부여를 지정합니다.

   Kafka 사용자 구성 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaUser
   metadata:
     name: my-user
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     authentication:
       type: tls
     authorization:
       type: simple
       acls:
         # Example consumer Acls for topic my-topic using consumer group my-group
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Read
           host: "*"
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Describe
           host: "*"
         - resource:
             type: group
             name: my-group
             patternType: literal
           operation: Read
           host: "*"
         # Example Producer Acls for topic my-topic
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Write
           host: "*"
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Create
           host: "*"
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operation: Describe
           host: "*"

2. OpenShift에서 KafkaUser 리소스를 생성합니다.

   oc apply -f <user_config_file>

3. 사용자의 준비 상태가 True 로 변경될 때까지 기다립니다.

   oc get kafkausers -o wide -w -n <namespace>

   Kafka 사용자 상태

   NAME       CLUSTER     AUTHENTICATION  AUTHORIZATION READY
   my-user-1  my-cluster  tls             simple        True
   my-user-2  my-cluster  tls             simple
   my-user-3  my-cluster  tls             simple        True

   READY 출력에 True 가 표시되면 사용자 생성이 성공합니다.

4. READY 열이 비어 있으면 리소스 YAML 또는 User Operator 로그에서 상태에 대한 자세한 정보를 가져옵니다.

   메시지는 현재 상태의 이유에 대한 세부 정보를 제공합니다.

   oc get kafkausers my-user-2 -o yaml

   NotReady 상태의 사용자 세부 정보

   # ...
   status:
     conditions:
     - lastTransitionTime: "2022-06-10T10:07:37.238065Z"
       message: Simple authorization ACL rules are configured but not supported in the
         Kafka cluster configuration.
       reason: InvalidResourceException
       status: "True"
       type: NotReady

   이 예에서 사용자가 준비되지 않은 이유는 Kafka 구성에서 간단한 권한이 활성화되지 않기 때문입니다.

   간단한 인증에 대한 Kafka 구성

     apiVersion: kafka.strimzi.io/v1beta2
     kind: Kafka
     metadata:
       name: my-cluster
     spec:
       kafka:
         # ...
         authorization:
           type: simple

   Kafka 구성을 업데이트하면 상태가 사용자가 준비되었음을 표시합니다.

   oc get kafkausers my-user-2 -o wide -w -n <namespace>

   사용자의 상태 업데이트

   NAME       CLUSTER     AUTHENTICATION  AUTHORIZATION READY
   my-user-2  my-cluster  tls             simple        True

   세부 정보를 가져오면 메시지가 표시되지 않습니다.

   oc get kafkausers my-user-2 -o yaml

   READY 상태의 사용자 세부 정보

   # ...
   status:
     conditions:
     - lastTransitionTime: "2022-06-10T10:33:40.166846Z"
       status: "True"
       type: Ready

절차

1. 필요에 따라 편집기에서 Kafka 클러스터 구성을 업데이트합니다.

   oc edit kafka MY-CLUSTER

2. Kafka 리소스의 spec.entityOperator.userOperator.resources 속성에서 User Operator에 대한 리소스 요청 및 제한을 설정합니다.

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # Kafka and ZooKeeper sections...
     entityOperator:
       userOperator:
         resources:
           requests:
             cpu: "1"
             memory: 500Mi
           limits:
             cpu: "1"
             memory: 500Mi

   파일을 저장하고 편집기를 종료합니다. Cluster Operator는 변경 사항을 자동으로 적용합니다.