27.12. 从持久性卷恢复集群

1. 当您可以恢复所有 KafkaTopic 资源时，请使用 选项 1。

   因此，必须在集群启动前恢复 KafkaTopic 资源，以便主题 Operator 不会删除对应的主题。

2. 当您无法恢复所有 KafkaTopic 资源时，请使用选项 2。

   在这种情况下，您可以在没有主题 Operator 的情况下部署集群，删除主题 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： 如果您拥有在丢失集群前存在 的所有 KafkaTopic 资源，包括 __consumer_offsets 中的提交偏移等内部主题：

   1. 重新创建所有 KafkaTopic 资源。

      在部署集群前，您必须重新创建资源，或者主题 Operator 将删除主题。

   2. 部署 Kafka 集群。

      例如：

      oc apply -f kafka.yaml

      Copy to Clipboard Toggle word wrap

   选项 2： 如果您没有在丢失集群前存在的所有 KafkaTopic 资源：

   1. 部署 Kafka 集群，与第一个选项一样，但在部署前，通过从 Kafka 资源中删除 topicOperator 属性来没有 Topic Operator。

      如果在部署中包含 Topic Operator，则主题 Operator 将删除所有主题。

   2. 从 Kafka 集群中删除内部主题存储主题：

      oc run kafka-admin -ti --image=registry.redhat.io/amq-streams/kafka-35-rhel8:2.5.1 --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 集群来启用 Topic Operator，以重新创建 KafkaTopic 资源。

      例如：

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

      1

      
          #...

      Copy to Clipboard Toggle word wrap

   1

   在这里，我们显示没有额外属性的默认配置。您可以使用 EntityTopicOperatorSpec schema reference 中所述的属性指定所需的配置。

7. 列出 KafkaTopic 资源来验证恢复：

   oc get KafkaTopic

   Copy to Clipboard Toggle word wrap