32장. Apache Kafka용 다운그레이드 스트림

프로세스

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

   kubectl edit kafka <kafka_configuration_file>

2. metadataVersion 버전을 현재 Kafka 버전과 대상 버전에서 모두 지원하는 값으로 변경합니다. Kafka 버전은 이 메타데이터 형식으로 작동할 수 있어야 합니다.

   현재 Kafka 버전에서 변경하지 않고 Kafka.spec.kafka.version 을 그대로 둡니다.

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

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
     annotations:
       strimzi.io/node-pools: enabled
       strimzi.io/kraft: enabled
   spec:
     kafka:
       replicas: 3
       metadataVersion: 3.9-IV0 

   1

   
       version: 4.0.0 

   2

   
       # ...

   1

   메타데이터 버전은 이전 Kafka 버전에서 지원하는 버전으로 변경됩니다.

   2

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

   참고

   metadataVersion 의 값은 부동 소수점 숫자로 해석되지 않도록 문자열이어야 합니다.

3. 변경 사항을 저장하고 Cluster Operator가 Kafka 리소스의 .status.kafkaMetadataVersion 을 업데이트할 때까지 기다립니다.

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

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

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
     annotations:
       strimzi.io/node-pools: enabled
       strimzi.io/kraft: enabled
   spec:
     kafka:
       replicas: 3
       metadataVersion: 3.9-IV0 

   1

   
       version: 3.9.0 

   2

   
       # ...

   1

   메타데이터 버전은 Kafka 버전에서 지원합니다.

   2

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

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

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

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

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

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

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