14.3. 部署 Cruise 控制指标报告器

在启动 Cruise Control 前,您必须将 Kafka 代理配置为使用提供的 Cruise Control Metrics Reporter。

在运行时载入时,Metric Reporter 会将指标发送到 __CruiseControlMetrics 主题,该主题由三个 自动创建的主题 之一。整合控制使用这些指标来创建和更新工作负载模型,并计算优化方法。

先决条件

流程

对于 Kafka 集群中的每个代理,一次一个代理:

  1. 停止 Kafka 代理:

    /opt/kafka/bin/kafka-server-stop.sh
  2. 将 Cruise Control Metrics Reporter .jar 文件复制到 Kafka 库目录中:

    cp /opt/cruise-control/libs/cruise-control-metrics-reporter-y.y.yyy.redhat-0000x.jar /opt/kafka/libs
  3. 在 Kafka 配置文件中(/opt/kafka/config/server.properties)配置 Cruise Control Metrics Reporter:

    1. CruiseControlMetricsReporter 类添加到 metric.reporters 配置选项中。不要删除任何现有的指标报告器。

      metric.reporters=com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
    2. 在 Kafka 配置文件中添加以下配置选项和值:

      cruise.control.metrics.topic.auto.create=true
      cruise.control.metrics.topic.num.partitions=1
      cruise.control.metrics.topic.replication.factor=1

      这些选项可让 Cruise Control Metrics Reporter 使用日志清理策略 DELETE 创建 __CruiseControlMetrics 主题。如需更多信息,请参阅 自动创建主题和 Cruise Control Metrics 主题的日志清理策略

  4. 如果需要,配置 SSL。

    1. 在 Kafka 配置文件中(/opt/kafka/config/server.properties)通过设置相关的客户端配置属性,在 Cruise Control Metrics Reporter 和 Kafka 代理之间配置 SSL。

      Metrics Reporter 使用 cruise.control.metrics.reporter 前缀接受所有特定于标准的配置属性。例如: cruise.control.metrics.reporter.ssl.truststore.password

    2. 在 Cruise Control 属性文件中(/opt/cruise-control/config/cruisecontrol.properties)通过设置相关的客户端配置属性,在 Kafka 代理和 Cruise Control 服务器之间配置 SSL。

      插入控制从 Kafka 继承 SSL 客户端属性选项,并将这些属性用于所有 Cruise Control 服务器客户端。

  5. 重启 Kafka 代理:

    /opt/kafka/bin/kafka-server-start.sh
  6. 为剩余的代理重复第 1-5 步。