24.2. Kafka 다운그레이드

절차

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

   oc edit kafka KAFKA-CONFIGURATION-FILE

2. Kafka.spec.kafka.version 을 변경하여 이전 버전을 지정합니다.

   예를 들어 Kafka 3.5.0에서 3.4.0으로 다운그레이드하는 경우:

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.4.0 

   1

   
       config:
         log.message.format.version: "3.4" 

   2

   
         inter.broker.protocol.version: "3.4" 

   3

   
         # ...

   1

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

   2

   메시지 형식 버전은 변경되지 않습니다.

   3

   inter-broker 프로토콜 버전은 변경되지 않습니다.

   참고

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

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

   참조 23.5.3절. “Kafka 버전 및 이미지 매핑”

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

   로그 또는 Pod 상태 전환을 확인하여 업데이트를 확인합니다.

   oc logs -f CLUSTER-OPERATOR-POD-NAME | grep -E "Kafka version downgrade from [0-9.]+ to [0-9.]+, phase ([0-9]+) of \1 completed"

   oc get pod -w

   INFO 수준 메시지가 있는지 Cluster Operator 로그를 확인합니다.

   Reconciliation #NUM(watch) Kafka(NAMESPACE/NAME): Kafka version downgrade from FROM-VERSION to TO-VERSION, phase 1 of 1 completed

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

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

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