11.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
         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

   Cruise Control 配置。可以提供标准的 Cruise Control 配置，仅限于不直接由 AMQ Streams 管理的这些属性。

   4

   优化目标配置，其中包括用于默认优化目标(default.goals)、主要优化目标（目标）和硬目标（硬.goals）的配置。

   5

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

   6

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

   7

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

   8

   模板自定义。这里的 pod 使用额外的安全属性调度。

   9

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

   10

   启用 Prometheus 指标。在本例中，为 Prometheus JMX 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 显示就绪/预期的副本数。当 AVAILABLE 输出显示为 1 时，部署成功。