29.3. 영구 볼륨에서 클러스터 복구

1. 모든 KafkaTopic 리소스를 복구할 수 있는 경우 옵션 1 을 사용합니다.

   따라서 KafkaTopic 리소스는 Topic Operator에서 해당 주제를 삭제하지 않도록 클러스터를 시작하기 전에 복구해야 합니다.

2. 모든 KafkaTopic 리소스를 복구할 수 없는 경우 옵션 2 를 사용합니다.

   이 경우 Topic Operator 없이 클러스터를 배포하고 Topic Operator 주제 저장소 메타데이터를 삭제한 다음 Topic Operator를 사용하여 Kafka 클러스터를 재배포하여 해당 주제에서 KafkaTopic 리소스를 다시 생성할 수 있습니다.

프로세스

1. 클러스터의 PV에 대한 정보를 확인합니다.

   oc get pv

   Copy to Clipboard Toggle word wrap

   데이터가 있는 PV에 대한 정보가 제공됩니다.

   다음 절차에 중요한 열을 보여주는 출력 예:

   NAME                                         RECLAIMPOLICY CLAIM
   pvc-5e9c5c7f-3317-11ea-a650-06e1eadd9a4c ... Retain ...    myproject/data-my-cluster-zookeeper-1
   pvc-5e9cc72d-3317-11ea-97b0-0aef8816c7ea ... Retain ...    myproject/data-my-cluster-zookeeper-0
   pvc-5ead43d1-3317-11ea-97b0-0aef8816c7ea ... Retain ...    myproject/data-my-cluster-zookeeper-2
   pvc-7e1f67f9-3317-11ea-a650-06e1eadd9a4c ... Retain ...    myproject/data-0-my-cluster-kafka-0
   pvc-7e21042e-3317-11ea-9786-02deaf9aa87e ... Retain ...    myproject/data-0-my-cluster-kafka-1
   pvc-7e226978-3317-11ea-97b0-0aef8816c7ea ... Retain ...    myproject/data-0-my-cluster-kafka-2

   Copy to Clipboard Toggle word wrap
   • NAME 에는 각 PV의 이름이 표시됩니다.
   • RECLAIM POLICY 는 PV가 유지되고 있음을 보여줍니다.
   • CLAIM 은 원래 PVC에 대한 링크를 보여줍니다.

2. 원래 네임스페이스를 다시 생성합니다.

   oc create namespace myproject

   Copy to Clipboard Toggle word wrap

3. 원래 PVC 리소스 사양을 다시 생성하여 PVC를 적절한 PV에 연결합니다.

   예를 들면 다음과 같습니다.

   apiVersion: v1
   kind: PersistentVolumeClaim
   metadata:
     name: data-0-my-cluster-kafka-0
   spec:
     accessModes:
     - ReadWriteOnce
     resources:
       requests:
         storage: 100Gi
     storageClassName: gp2-retain
     volumeMode: Filesystem
     volumeName: pvc-7e1f67f9-3317-11ea-a650-06e1eadd9a4c

   Copy to Clipboard Toggle word wrap

4. PV 사양을 편집하여 원래 PVC를 바인딩된 claimRef 속성을 삭제합니다.

   예를 들면 다음과 같습니다.

   apiVersion: v1
   kind: PersistentVolume
   metadata:
     annotations:
       kubernetes.io/createdby: aws-ebs-dynamic-provisioner
       pv.kubernetes.io/bound-by-controller: "yes"
       pv.kubernetes.io/provisioned-by: kubernetes.io/aws-ebs
     creationTimestamp: "<date>"
     finalizers:
     - kubernetes.io/pv-protection
     labels:
       failure-domain.beta.kubernetes.io/region: eu-west-1
       failure-domain.beta.kubernetes.io/zone: eu-west-1c
     name: pvc-7e226978-3317-11ea-97b0-0aef8816c7ea
     resourceVersion: "39431"
     selfLink: /api/v1/persistentvolumes/pvc-7e226978-3317-11ea-97b0-0aef8816c7ea
     uid: 7efe6b0d-3317-11ea-a650-06e1eadd9a4c
   spec:
     accessModes:
     - ReadWriteOnce
     awsElasticBlockStore:
       fsType: xfs
       volumeID: aws://eu-west-1c/vol-09db3141656d1c258
     capacity:
       storage: 100Gi
     claimRef:
       apiVersion: v1
       kind: PersistentVolumeClaim
       name: data-0-my-cluster-kafka-2
       namespace: myproject
       resourceVersion: "39113"
       uid: 54be1c60-3319-11ea-97b0-0aef8816c7ea
     nodeAffinity:
       required:
         nodeSelectorTerms:
         - matchExpressions:
           - key: failure-domain.beta.kubernetes.io/zone
             operator: In
             values:
             - eu-west-1c
           - key: failure-domain.beta.kubernetes.io/region
             operator: In
             values:
             - eu-west-1
     persistentVolumeReclaimPolicy: Retain
     storageClassName: gp2-retain
     volumeMode: Filesystem

   Copy to Clipboard Toggle word wrap

   이 예제에서는 다음 속성이 삭제됩니다.

   claimRef:
     apiVersion: v1
     kind: PersistentVolumeClaim
     name: data-0-my-cluster-kafka-2
     namespace: myproject
     resourceVersion: "39113"
     uid: 54be1c60-3319-11ea-97b0-0aef8816c7ea

   Copy to Clipboard Toggle word wrap

5. Cluster Operator를 배포합니다.

   oc create -f install/cluster-operator -n my-project

   Copy to Clipboard Toggle word wrap

6. 클러스터를 다시 생성합니다.

   클러스터를 다시 생성하는 데 필요한 모든 KafkaTopic 리소스가 있는지 여부에 따라 단계를 따르십시오.

   옵션 1: __consumer_offsets 의 커밋된 오프셋과 같은 내부 주제를 포함하여 클러스터를 손실하기 전에 존재하는 모든 KafkaTopic 리소스가 있는 경우 :

   1. 모든 KafkaTopic 리소스를 다시 생성합니다.

      클러스터를 배포하기 전에 리소스를 다시 생성해야 합니다. 그러지 않으면 Topic Operator에서 주제를 삭제해야 합니다.

   2. Kafka 클러스터를 배포합니다.

      예를 들면 다음과 같습니다.

      oc apply -f kafka.yaml

      Copy to Clipboard Toggle word wrap

   옵션 2: 클러스터를 손실하기 전에 존재하는 모든 KafkaTopic 리소스가 없는 경우:

   1. 첫 번째 옵션과 마찬가지로 Kafka 클러스터를 배포하지만, 배포하기 전에 Kafka 리소스에서 topicOperator 속성을 제거하여 Topic Operator 없이 Kafka 클러스터를 배포합니다.

      Topic Operator를 배포에 포함하는 경우 Topic Operator는 모든 주제를 삭제합니다.

   2. Kafka 클러스터에서 내부 주제 저장소 주제를 삭제합니다.

      oc run kafka-admin -ti --image=registry.redhat.io/amq-streams/kafka-37-rhel9:2.7.0 --rm=true --restart=Never -- ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic __strimzi-topic-operator-kstreams-topic-store-changelog --delete && ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic __strimzi_store_topic --delete

      Copy to Clipboard Toggle word wrap

      명령은 Kafka 클러스터에 액세스하는 데 사용되는 리스너 및 인증 유형에 해당해야 합니다.

   3. topicOperator 속성으로 Kafka 클러스터를 재배포하여 KafkaTopic 리소스를 다시 생성하여 Topic Operator를 활성화합니다.

      예를 들면 다음과 같습니다.

      apiVersion: kafka.strimzi.io/v1beta2
      kind: Kafka
      metadata:
        name: my-cluster
      spec:
        #...
        entityOperator:
          topicOperator: {} 

      1

      
          #...

      Copy to Clipboard Toggle word wrap

   1

   여기서는 추가 속성이 없는 기본 구성을 보여줍니다. EntityTopicOperatorSpec 스키마 참조에 설명된 속성을 사용하여 필요한 구성을 지정합니다.

7. KafkaTopic 리소스를 나열하여 복구를 확인합니다.

   oc get KafkaTopic

   Copy to Clipboard Toggle word wrap