6.3. Topic Operator 사용

절차

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

   Kafka 주제 구성의 예

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaTopic
   metadata:
     name: orders
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 10
     replicas: 2

   Copy to Clipboard Toggle word wrap

   작은 정보

   주제를 수정할 때 oc get kafkatopic orders -o yaml 을 사용하여 현재 버전의 리소스를 가져올 수 있습니다.

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

   oc apply -f <topic_config_file>

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

   Kafka 주제 상태

   NAME         CLUSTER     PARTITIONS  REPLICATION FACTOR READY
   my-topic-1   my-cluster  10          3                  True
   my-topic-2   my-cluster  10          3
   my-topic-3   my-cluster  10          3                  True

   Copy to Clipboard Toggle word wrap

   READY 출력에 True 가 표시되면 주제 생성이 성공합니다.

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

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

   oc get kafkatopics my-topic-2 -o yaml

   Copy to Clipboard Toggle word wrap

   NotReady 상태의 주제 세부 정보

   # ...
   status:
     conditions:
     - lastTransitionTime: "2022-06-13T10:14:43.351550Z"
       message: Number of partitions cannot be decreased
       reason: PartitionDecreaseException
       status: "True"
       type: NotReady

   Copy to Clipboard Toggle word wrap

   이 예에서 주제가 준비되지 않은 이유는 KafkaTopic 구성에서 원래 파티션 수가 감소되었기 때문입니다. Kafka는 이를 지원하지 않습니다.

   주제 구성을 재설정한 후 상태에 주제가 준비됨으로 표시됩니다.

   oc get kafkatopics my-topic-2 -o wide -w -n <namespace>

   Copy to Clipboard Toggle word wrap

   주제의 상태 업데이트

   NAME         CLUSTER     PARTITIONS  REPLICATION FACTOR READY
   my-topic-2   my-cluster  10          3                  True

   Copy to Clipboard Toggle word wrap

   세부 정보 가져오기에 메시지가 표시되지 않음

   oc get kafkatopics my-topic-2 -o yaml

   Copy to Clipboard Toggle word wrap

   READY 상태의 주제 세부 정보

   # ...
   status:
     conditions:
     - lastTransitionTime: '2022-06-13T10:15:03.761084Z'
       status: 'True'
       type: Ready

   Copy to Clipboard Toggle word wrap

절차

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

   oc edit kafka MY-CLUSTER

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

3. 새 구성을 적용하여 리소스를 생성하거나 업데이트합니다.

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap