7.5. 使用 Kafka 配置和部署 Cruise 控制

流程

1. 编辑 Kafka 资源的 cruiseControl 属性。

   您可以在以下示例配置中显示您可以配置的属性：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     # ...
     cruiseControl:
       brokerCapacity: 

   1

   
         inboundNetwork: 10000KB/s
         outboundNetwork: 10000KB/s
         # ...
       config: 

   2

   
         default.goals: > 

   3

   
           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.NetworkInboundCapacityGoal,
           com.linkedin.kafka.cruisecontrol.analyzer.goals.NetworkOutboundCapacityGoal
           # ...
         cpu.balance.threshold: 1.1
         metadata.max.age.ms: 300000
         send.buffer.bytes: 131072
         webserver.http.cors.enabled: true 

   4

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

   5

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

   6

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

   7

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

   8

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

   9

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

   Copy to Clipboard Toggle word wrap

   1

   代理资源的容量限制。

   2

   断路器控制配置.可以提供标准 Cruise Control 配置，仅限于不直接由 AMQ Streams 管理的属性。

   3

   优化目标配置，可包括用于默认优化目标的配置(默认为)、主要优化目标(目标)和硬目标(hard.goals)。

   4

   为对 Cruise Control API 的只读访问 启用并配置 CORS。

   5

   用于保留 支持的资源、当前 cpu 和内存 的请求，以及指定可消耗的最大资源数量。

   6

   通过 ConfigMap 直接添加(内联)或间接(外部 )的控制 日志记录器和日志级别。自定义 ConfigMap 必须放在 log4j.properties 键下。Cruise Control 有一个名为 rootLogger.level 的单个日志记录器。您可以将日志级别设置为 INFO、ERROR、WARN、TRACE、DEBUG、FATAL 或 OFF。

   7

   模板自定义。此处为 pod 调度了额外的安全属性。

   8

   状况检查，了解何时重启容器（持续）以及容器是否可以接受流量（就绪状态）。

   9

   启用 Prometheus 指标。在本例中，为 Prometheus JMX Exporter 配置指标（默认指标导出器）。

2. 创建或更新资源：

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

3. 检查部署的状态：

   oc get deployments -n <my_cluster_operator_namespace>

   Copy to Clipboard Toggle word wrap

   输出显示了部署名称和就绪状态

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

   Copy to Clipboard Toggle word wrap

   my-cluster 是 Kafka 集群的名称。

   READY 显示 ready/expected 的副本数量。当 AVAILABLE 输出显示为 1 时，部署成功。