21.2. Kafka를 사용하여 Cruise Control 배포

프로세스

1. Kafka 리소스의 cruiseControl 속성을 편집합니다.

   구성할 수 있는 속성은 이 예제 구성에 표시됩니다.

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
     annotations:
       strimzi.io/node-pools: enabled
       strimzi.io/kraft: enabled
   spec:
     # ...
     cruiseControl:
       brokerCapacity: 

   1

   
         inboundNetwork: 10000KB/s
         outboundNetwork: 10000KB/s
         overrides: 

   2

   
         - brokers: [0]
           inboundNetwork: 20000KiB/s
           outboundNetwork: 20000KiB/s
         - brokers: [1, 2]
           inboundNetwork: 30000KiB/s
           outboundNetwork: 30000KiB/s
         # ...
       config: 

   3

   
         # Note that `default.goals` (superset) must also include all `hard.goals` (subset)
         default.goals: > 

   4

   
           com.linkedin.kafka.cruisecontrol.analyzer.goals.RackAwareGoal,
           com.linkedin.kafka.cruisecontrol.analyzer.goals.ReplicaCapacityGoal,
           com.linkedin.kafka.cruisecontrol.analyzer.goals.DiskCapacityGoal
           # ...
         hard.goals: >
           com.linkedin.kafka.cruisecontrol.analyzer.goals.RackAwareGoal
           # ...
         cpu.balance.threshold: 1.1
         metadata.max.age.ms: 300000
         send.buffer.bytes: 131072
         webserver.http.cors.enabled: true 

   5

   
         webserver.http.cors.origin: "*"
         webserver.http.cors.exposeheaders: "User-Task-ID,Content-Type"
         # ...
       resources: 

   6

   
         requests:
           cpu: 1
           memory: 512Mi
         limits:
           cpu: 2
           memory: 2Gi
       logging: 

   7

   
           type: inline
           loggers:
             rootLogger.level: INFO
       template: 

   8

   
         pod:
           metadata:
             labels:
               label1: value1
           securityContext:
             runAsUser: 1000001
             fsGroup: 0
           terminationGracePeriodSeconds: 120
       readinessProbe: 

   9

   
         initialDelaySeconds: 15
         timeoutSeconds: 5
       livenessProbe:
         initialDelaySeconds: 15
         timeoutSeconds: 5
       metricsConfig: 

   10

   
         type: jmxPrometheusExporter
         valueFrom:
           configMapKeyRef:
             name: cruise-control-metrics
             key: metrics-config.yml
   # ...

   1

   브로커 리소스에 대한 용량 제한입니다.

   2

   덮어쓰기는 이기종 네트워크 리소스가 있는 노드에서 실행할 때 특정 브로커에 대한 네트워크 용량 제한을 설정합니다.

   3

   크루즈 제어 구성. 표준 크루즈 컨트롤 구성은 Apache Kafka용 Streams에서 직접 관리하지 않는 속성으로 제공될 수 있습니다.

   4

   최적화 목표 구성: 기본 최적화 목표(default.goals), 지원되는 최적화 목표(대상) 및 하드목표(hard.goals)를 위한 구성이 포함될 수 있습니다.

   5

   CORS를 활성화하고 Cruise Control API에 대한 읽기 전용 액세스를 위해 구성되었습니다.

   6

   지원되는 리소스(현재 cpu 및 memory ) 예약 요청 및 사용할 수 있는 최대 리소스를 지정합니다.

   7

   크루즈 제어 로거 및 로그 수준은 ConfigMap 을 통해 직접(인라인) 또는 간접적으로(외부)에 추가됩니다. 사용자 정의 Log4j 구성은 ConfigMap 의 log4j2.properties 키 아래에 배치해야 합니다. 로그 수준은 INFO,ERROR,WARN,TRACE,DEBUG,FATAL 또는 OFF 로 설정할 수 있습니다.

   8

   템플릿 사용자 지정. 여기에서 Pod는 추가 보안 특성으로 예약됩니다.

   9

   컨테이너를 다시 시작할 시기(라이브)와 컨테이너가 트래픽을 허용할 시기(준비)를 확인할 상태 점검입니다.

   10

   Prometheus 지표가 활성화되어 있습니다. 이 예에서는 Prometheus Cryostat Exporter(기본 지표 내보내기)에 대한 메트릭이 구성됩니다.

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

   oc apply -f <kafka_configuration_file>

3. 배포 상태를 확인합니다.

   oc get deployments -n <my_cluster_operator_namespace>

   출력에 배포 이름 및 준비 상태 표시

   NAME                      READY  UP-TO-DATE  AVAILABLE
   my-cluster-cruise-control 1/1    1           1

   my-cluster 는 Kafka 클러스터의 이름입니다.

   READY 는 ready/expected 복제본 수를 표시합니다. AVAILABLE 출력에 1 이 표시되면 배포가 성공적으로 수행됩니다.