23.5. Kafka 업그레이드

절차

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

   oc edit kafka <my_cluster>

2. 구성된 경우 inter.broker.protocol.version 및 log.message.format.version 속성이 현재 버전으로 설정되어 있는지 확인합니다.

   예를 들어 Kafka 버전 3.4.0에서 3.5.0으로 업그레이드하는 경우 현재 버전은 3.4입니다.

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

   log.message.format.version 및 inter.broker.protocol.version 이 구성되지 않은 경우 AMQ 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.4.0에서 3.5.0으로 업그레이드하는 경우 다음을 수행합니다.

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

   1

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

   2

   
         inter.broker.protocol.version: "3.4" 

   3

   
         # ...

   1

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

   2

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

   3

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

   주의

   새 Kafka 버전의 inter.broker.protocol.version 이 변경되면 Kafka를 다운그레이드할 수 없습니다. The inter-broker protocol version determines the schemas used for persistent metadata stored by the broker, including messages written to __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}'

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

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

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

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

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

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

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

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

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

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

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

   중요

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

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

    • Kafka 클러스터 및 클라이언트는 이제 새 Kafka 버전을 사용합니다.
    • 브로커는 inter-broker 프로토콜 버전과 Kafka의 새 버전의 메시지 형식 버전을 사용하여 메시지를 전송하도록 구성됩니다.