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

29장. Apache Kafka용 스트림 관리

Apache Kafka용 Streams를 관리하려면 Kafka 클러스터 및 관련 리소스가 원활하게 실행되도록 다양한 작업을 수행해야 합니다. oc 명령을 사용하여 리소스의 상태를 확인하고, 롤링 업데이트에 대한 유지 관리 창을 구성하고, Apache Kafka Drain cleaner 및 Kafka Static Quota 플러그인과 같은 툴을 활용하여 배포를 효과적으로 관리합니다.

29.1. 롤링 업데이트를 위한 유지 관리 기간
링크 복사

유지 관리 시간 창을 사용하면 Kafka 및 Zoo Cryostat 클러스터의 특정 롤링 업데이트를 편리한 시간에 시작할 수 있습니다.

29.1.1. 유지 관리 시간 창 개요
링크 복사

대부분의 경우 Cluster Operator는 해당 Kafka 리소스에 대한 변경 사항에 따라 Kafka 또는 Zoo Cryostat 클러스터만 업데이트합니다. 이를 통해 Kafka 리소스에 변경 사항을 적용할 시기를 계획하여 Kafka 클라이언트 애플리케이션에 미치는 영향을 최소화할 수 있습니다.

그러나 Kafka 및 Zoo Cryostat 클러스터에 대한 일부 업데이트는 Kafka 리소스를 변경하지 않고 발생할 수 있습니다. 예를 들어 관리하는 CA(인증 기관) 인증서가 만료되기 가까운 경우 Cluster Operator는 롤링 재시작을 수행해야 합니다.

Pod를 롤링 재시작하면 서비스 가용성에 영향을 미치지 않지만(올바른 브로커 및 주제 구성 가정) Kafka 클라이언트 애플리케이션의 성능 에 영향을 미칠 수 있습니다. 유지 관리 시간 창을 사용하면 Kafka 및 Zoo Cryostat 클러스터의 자동 롤링 업데이트를 편리한 시간에 시작할 수 있습니다. 유지 관리 시간 창이 클러스터에 대해 구성되지 않은 경우 예측 가능한 로드 기간 동안과 같이 이러한 무관한 롤링 업데이트가 불편한 시간에 발생할 수 있습니다.

29.1.2. 유지 관리 시간 창 정의
링크 복사

Kafka.spec.maintenanceTimeWindows 속성에 문자열 배열을 입력하여 유지 관리 시간 창을 구성합니다. 각 문자열은 UTC (Coordinated Universal Time)로 해석되는 cron 표현식 입니다. 실용적인 목적으로는 Greenwich Mean Time과 동일합니다.

다음 예제에서는 자정에 시작하여 오전 01:59am (UTC), 일요일, 월요일, 화요일, 수요일 및 목요일에 종료되는 단일 유지 관리 시간 창을 구성합니다. 

# ...
maintenanceTimeWindows:
  - "* * 0-1 ? * SUN,MON,TUE,WED,THU *"
# ...
Copy to Clipboard Toggle word wrap

실제로 유지 관리 창은 Kafka 리소스의 Kafka.spec.clusterCa.renewalDays 및 Kafka.spec.clientsCa.renewalDays 속성과 함께 설정하여 필요한 CA 인증서 갱신을 구성된 유지 관리 시간 창에서 완료할 수 있도록 해야 합니다.

참고

Apache Kafka의 스트림은 지정된 창에 따라 정확히 유지 관리 작업을 예약하지 않습니다. 대신 각 조정에 대해 유지 관리 기간이 현재 "오픈"인지 확인합니다. 즉, 지정된 시간 내에 유지 관리 작업 시작이 Cluster Operator 조정 간격까지 지연될 수 있습니다. 따라서 유지 관리 시간은 이 기간 이상이어야 합니다.

29.1.3. 유지 관리 시간 창 구성
링크 복사

지원되는 프로세스에서 트리거한 롤링 업데이트에 대한 유지 관리 시간 창을 구성할 수 있습니다.

사전 요구 사항

  • OpenShift 클러스터입니다.
  • Cluster Operator가 실행 중입니다.

프로세스

  1. Kafka 리소스에서 maintenanceTimeWindows 속성을 추가하거나 편집합니다. 예를 들어 0800에서 1059 사이와 1400에서 1559 사이의 유지 관리를 허용하려면 다음과 같이 maintenanceTimeWindows 를 설정합니다. 

    apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    # ...
  zookeeper:
    # ...
  maintenanceTimeWindows:
    - "* * 8-10 * * ?"
    - "* * 14-15 * * ?"
    Copy to Clipboard Toggle word wrap

  2. 리소스를 생성하거나 업데이트합니다. 

    oc apply -f <kafka_configuration_file>
    Copy to Clipboard Toggle word wrap
맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

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

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

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

Red Hat 소개

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

Theme

© 2025 Red Hat