10장. User Operator를 사용하여 Kafka 사용자 관리

절차

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

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

   Kafka 사용자 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaUser
   metadata:
     name: my-user-1
     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
           operations:
             - Describe
             - Read
           host: "*"
         - resource:
             type: group
             name: my-group
             patternType: literal
           operations:
             - Read
           host: "*"
         # Example Producer Acls for topic my-topic
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operations:
             - Create
             - Describe
             - Write
           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