25.7. 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 버전 3.6.0에서 3.7.0으로 업그레이드하는 경우 현재 버전은 3.6입니다.

   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.6.0
       config:
         log.message.format.version: "3.6"
         inter.broker.protocol.version: "3.6"
         # ...

   Copy to Clipboard Toggle word wrap

   log.message.format.version 및 inter.broker.protocol.version 이 구성되지 않은 경우 Apache Kafka의 Streams는 다음 단계에서 Kafka 버전으로 업데이트한 후 이러한 버전을 현재 기본값으로 자동으로 업데이트합니다.

   참고

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

3. Kafka.spec.kafka.version 을 변경하여 새 Kafka 버전을 지정하고, 현재 Kafka 버전의 기본값으로 log.message.format.version 및 inter.broker.protocol.version 을 남겨 둡니다.

   참고

   kafka.version 을 변경하면 클러스터의 모든 브로커가 새 브로커 바이너리를 사용하도록 업그레이드됩니다. 이 프로세스 중에 일부 브로커는 이전 바이너리를 사용하고 있지만 다른 브로커는 이미 새 바이너리로 업그레이드했습니다. 현재 설정에서 inter.broker.protocol.version 을 변경하지 않으면 브로커가 업그레이드 중에 계속 서로 통신할 수 있습니다.

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

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

   1

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

   2

   
         inter.broker.protocol.version: "3.6" 

   3

   
         # ...

   Copy to Clipboard Toggle word wrap

   1

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

   2

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

   3

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

   주의

   새 Kafka 버전의 inter.broker.protocol.version 이 변경되면 Kafka를 다운그레이드할 수 없습니다. inter-broker 프로토콜 버전은 __consumer_offsets 에 기록된 메시지를 포함하여 브로커가 저장한 영구 메타데이터에 사용되는 스키마를 결정합니다. 다운그레이드된 클러스터는 메시지를 이해할 수 없습니다.

4. Kafka 클러스터의 이미지가 Kafka 사용자 정의 리소스의 Kafka.spec.kafka. image 에 정의된 경우 새 Kafka 버전이 있는 컨테이너 이미지를 가리키도록 이미지를 업데이트합니다.

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

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

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

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

   Copy to Clipboard Toggle word wrap

   롤링 업데이트를 통해 각 pod가 새 Kafka 버전에 브로커 바이너리를 사용하고 있는지 확인합니다.

6. 클라이언트를 업그레이드하기 위한 선택한 전략에 따라 모든 클라이언트 애플리케이션을 업그레이드하여 새 버전의 클라이언트 바이너리를 사용합니다.

   필요한 경우 Kafka Connect 및 MirrorMaker의 버전 속성을 Kafka의 새 버전으로 설정합니다.

   1. Kafka Connect의 경우 KafkaConnect.spec.version 을 업데이트합니다.
   2. MirrorMaker의 경우 KafkaMirrorMaker.spec.version 을 업데이트합니다.

   3. MirrorMaker 2의 경우 KafkaMirrorMaker2.spec.version 을 업데이트합니다.

      참고

      수동으로 빌드된 사용자 지정 이미지를 사용하는 경우 해당 이미지를 다시 빌드하여 Apache Kafka 기본 이미지의 최신 스트림으로 최신 이미지인지 확인해야 합니다. 예를 들어 기본 Kafka Connect 이미지에서 컨테이너 이미지를 생성한 경우 최신 기본 이미지 및 빌드 구성을 가리키도록 Dockerfile을 업데이트합니다.

7. 업그레이드된 클라이언트 애플리케이션이 새 Kafka 브로커에서 올바르게 작동하는지 확인합니다.

8. 구성된 경우 새 inter.broker.protocol.version 버전을 사용하도록 Kafka 리소스를 업데이트합니다. 그렇지 않으면 9단계로 이동합니다.

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

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     # ...
     kafka:
       version: 3.7.0
       config:
         log.message.format.version: "3.6"
         inter.broker.protocol.version: "3.7"
         # ...

   Copy to Clipboard Toggle word wrap
9. Cluster Operator가 클러스터를 업데이트할 때까지 기다립니다.

10. 구성된 경우 새 log.message.format.version 버전을 사용하도록 Kafka 리소스를 업데이트합니다. 그렇지 않으면 10 단계로 이동합니다.

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

    apiVersion: kafka.strimzi.io/v1beta2
    kind: Kafka
    spec:
      # ...
      kafka:
        version: 3.7.0
        config:
          log.message.format.version: "3.7"
          inter.broker.protocol.version: "3.7"
          # ...

    Copy to Clipboard Toggle word wrap
    중요

    Kafka 3.0.0에서 inter.broker.protocol.version 이 3.0 이상으로 설정되면 log.message.format.version 옵션이 무시되고 설정할 필요가 없습니다.

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

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