26.3. Zoo Cryostat를 사용할 때 Kafka 다운그레이드

프로세스

1. Kafka 클러스터 구성을 업데이트합니다.

   oc edit kafka <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

2. inter.broker.protocol.version 버전(및 log.message.format.version )을 다운그레이드하려는 Kafka 버전에서 지원하는 버전으로 변경합니다. Kafka.spec.kafka.version 은 현재 Kafka 버전에서 변경되지 않은 상태로 둡니다.

   예를 들어 Kafka 3.7.0에서 3.6.0으로 다운그레이드하는 경우 다음을 수행합니다.

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     # ...
     kafka:
       version: 3.7.0 

   1

   
       config:
         inter.broker.protocol.version: "3.6" 

   2

   
         log.message.format.version: "3.6"
         # ...

   Copy to Clipboard Toggle word wrap

   1

   Kafka 버전은 변경되지 않습니다.

   2

   broker 프로토콜 버전이 이전 Kafka 버전에서 지원하는 버전으로 변경됩니다.

   참고

   log.message.format.version 및 inter.broker.protocol.version 의 값은 부동 소수점 숫자로 해석되지 않도록 문자열이어야 합니다.

3. 편집기를 저장하고 종료한 다음 롤링 업데이트가 완료될 때까지 기다립니다.

   Pod 상태 전환을 확인하여 롤링 업데이트의 진행 상황을 확인합니다.

   oc get pods my-cluster-kafka-0 -o jsonpath='{.spec.containers[0].image}'

   Copy to Clipboard Toggle word wrap

   롤링 업데이트를 통해 각 pod가 지정된 Kafka 간 프로토콜 버전을 사용하고 있습니다.

4. Kafka.spec.kafka.version 을 이전 버전으로 변경합니다.

   예를 들어 Kafka 3.7.0에서 3.6.0으로 다운그레이드하는 경우 다음을 수행합니다.

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     # ...
     kafka:
       version: 3.6.0 

   1

   
       config:
         inter.broker.protocol.version: "3.6" 

   2

   
         log.message.format.version: "3.6"
         # ...

   Copy to Clipboard Toggle word wrap

   1

   Kafka 버전이 새 버전으로 변경되었습니다.

   2

   broker 간 프로토콜 버전은 Kafka 버전에서 지원됩니다.

5. Kafka 버전의 이미지가 Cluster Operator의 STRIMZI_KAFKA_IMAGES 에 정의된 이미지와 다른 경우 Kafka.spec.kafka.image 를 업데이트합니다.

   25.2.3절. “Kafka 버전 및 이미지 매핑”을 참조하십시오.

6. Cluster Operator가 클러스터를 업데이트할 때까지 기다립니다.

   Kafka 리소스 상태에서 다운그레이드가 성공적으로 완료되었는지 확인할 수 있습니다.

7. 이전 버전의 클라이언트 바이너리를 사용하도록 모든 클라이언트 애플리케이션(consumers)을 다운그레이드합니다.

   Kafka 클러스터 및 클라이언트는 이제 이전 Kafka 버전을 사용하고 있습니다.

8. 주제 메타데이터 스토리지에 Zoo Cryostat를 사용하는 1.7 이전의 Apache Kafka용 Streams 버전으로 되돌리는 경우 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