Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

29.2. 주석을 사용하여 Kafka 및 기타 피연산자의 롤링 업데이트 시작

Apache Kafka의 스트림은 Cluster Operator를 통해 Kafka 및 기타 피연산자의 롤링 업데이트를 수동으로 트리거하는 주석 사용을 지원합니다. 주석을 사용하여 Kafka, Kafka Connect, MirrorMaker 2 및 Zoo Cryostat 클러스터의 롤링 업데이트를 시작합니다.

일반적으로 특정 Pod 또는 Pod 세트에서 롤링 업데이트를 수동으로 수행하는 것은 예외적인 경우에만 필요합니다. 그러나 Pod를 직접 삭제하지 않고 Cluster Operator를 통해 롤링 업데이트를 수행하면 다음을 확인합니다.

  • Pod의 수동 삭제는 동시에 다른 Pod 삭제와 같은 동시 Cluster Operator 작업과 충돌하지 않습니다.
  • Cluster Operator 논리는 동기화 중인 복제본 수와 같은 Kafka 구성 사양을 처리합니다.

29.2.1. Pod 관리 주석을 사용하여 롤링 업데이트 수행
링크 복사

다음 절차에서는 Kafka, Kafka Connect, MirrorMaker 2, 또는 Zoo Cryostat 클러스터의 롤링 업데이트를 트리거하는 방법을 설명합니다. 업데이트를 트리거하려면 클러스터에서 실행 중인 Pod를 관리하는 StrimziPodSet 에 주석을 추가합니다.

사전 요구 사항

수동 롤링 업데이트를 수행하려면 실행 중인 Cluster Operator가 필요합니다. Kafka, Kafka Connect, MirrorMaker 2 또는 Zoo Cryostat와 관계없이 업데이트할 구성 요소의 클러스터도 실행 중이어야 합니다.

프로세스

  1. 수동으로 업데이트할 Pod를 제어하는 리소스의 이름을 찾습니다.

    예를 들어 Kafka 클러스터 이름이 my-cluster 인 경우 해당 이름은 my-cluster-kafka 및 my-cluster-zookeeper 입니다. my-connect-cluster 라는 Kafka Connect 클러스터의 경우 해당 이름은 my-connect-cluster-connect 입니다. my-mm2-cluster 라는 MirrorMaker 2 클러스터의 경우 해당 이름은 my-mm2-cluster-mirrormaker2 입니다.

  2. oc annotate 를 사용하여 OpenShift에서 적절한 리소스에 주석을 답니다.

    StrimziPodSet 주석 처리

    oc annotate strimzipodset <cluster_name>-kafka strimzi.io/manual-rolling-update="true"

oc annotate strimzipodset <cluster_name>-zookeeper strimzi.io/manual-rolling-update="true"

oc annotate strimzipodset <cluster_name>-connect strimzi.io/manual-rolling-update="true"

oc annotate strimzipodset <cluster_name>-mirrormaker2 strimzi.io/manual-rolling-update="true"
    Copy to Clipboard Toggle word wrap

  3. 다음 조정이 발생할 때까지 기다립니다(기본적으로 2분마다). 조정 프로세스에서 주석을 감지한 한 주석이 주석으로 감지되면 주석이 주석에 있는 모든 Pod의 롤링 업데이트가 트리거됩니다. 모든 Pod의 롤링 업데이트가 완료되면 리소스에서 주석이 자동으로 제거됩니다.

29.2.2. Pod 주석을 사용하여 롤링 업데이트 수행
링크 복사

다음 절차에서는 OpenShift Pod 주석을 사용하여 기존 Kafka, Kafka Connect, MirrorMaker 2 또는 Zoo Cryostat 클러스터의 롤링 업데이트를 수동으로 트리거하는 방법을 설명합니다. 여러 Pod에 주석이 있으면 동일한 조정 실행 내에서 연속 롤링 업데이트가 수행됩니다.

사전 요구 사항

수동 롤링 업데이트를 수행하려면 실행 중인 Cluster Operator가 필요합니다. Kafka, Kafka Connect, MirrorMaker 2 또는 Zoo Cryostat와 관계없이 업데이트할 구성 요소의 클러스터도 실행 중이어야 합니다.

사용된 주제 복제 요인에 관계없이 Kafka 클러스터에서 롤링 업데이트를 수행할 수 있습니다. 그러나 Kafka가 업데이트 중에 작동하려면 다음이 필요합니다.

  • 업데이트하려는 노드에서 실행되는 고가용성 Kafka 클러스터 배포입니다.

  • 고가용성을 위해 복제된 주제입니다.

    주제 구성은 복제 요소보다 최소 3개 이상 및 최소 동기화된 복제본 수를 1개로 지정합니다.

    고가용성을 위해 Kafka 주제 복제

    apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
  name: my-topic
  labels:
    strimzi.io/cluster: my-cluster
spec:
  partitions: 1
  replicas: 3
  config:
    # ...
    min.insync.replicas: 2
    # ...
    Copy to Clipboard Toggle word wrap

프로세스

  1. 수동으로 업데이트할 Pod 이름을 찾습니다.

    Pod 이름 지정 규칙은 다음과 같습니다.

    • Kafka 클러스터의 <CLUSTER_NAME>-kafka-<index_number >
    • <CLUSTER_NAME>-zookeeper-<index_number >
    • Kafka Connect 클러스터의 <CLUSTER_NAME>-connect-<index_number >
    • <CLUSTER_NAME>-mirrormaker2-<index_number > 2 클러스터의 경우

    Pod에 할당된 < index_number >는 0에서 시작하여 총 복제본 수에서 1을 뺀 값입니다.

  2. oc annotate 를 사용하여 OpenShift에서 Pod 리소스에 주석을 답니다. 

    oc annotate pod <cluster_name>-kafka-<index_number> strimzi.io/manual-rolling-update="true"

oc annotate pod <cluster_name>-zookeeper-<index_number> strimzi.io/manual-rolling-update="true"

oc annotate pod <cluster_name>-connect-<index_number> strimzi.io/manual-rolling-update="true"

oc annotate pod <cluster_name>-mirrormaker2-<index_number> strimzi.io/manual-rolling-update="true"
    Copy to Clipboard Toggle word wrap
  3. 다음 조정이 발생할 때까지 기다립니다(기본적으로 2분마다). 조정 프로세스에서 주석이 감지된 한 주석이 주석에 감지되면 주석이 주석의 롤링 업데이트가 트리거됩니다. Pod의 롤링 업데이트가 완료되면 Pod 에서 주석이 자동으로 제거됩니다.
맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat