9.4. Kafka 주제 구성

절차

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

   Kafka 주제 구성의 예

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

   작은 정보

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

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

   oc apply -f <topic_config_file>

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

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

   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

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

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

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

   oc get kafkatopics my-topic-2 -o yaml

   NotReady 상태가 있는 항목에 대한 세부 정보

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

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

   주제 구성을 재설정하면 상태에 주제가 준비되었음이 표시됩니다.

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

   주제의 상태 업데이트

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

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

   oc get kafkatopics my-topic-2 -o yaml

   READY 상태가 있는 항목에 대한 세부 정보

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