14.3. 部署 Cruise 控制指标报告器
在启动 Cruise Control 前,您必须将 Kafka 代理配置为使用提供的 Cruise Control Metrics Reporter。
在运行时载入时,Metric Reporter 会将指标发送到 __CruiseControlMetrics
主题,该主题由三个 自动创建的主题 之一。整合控制使用这些指标来创建和更新工作负载模型,并计算优化方法。
先决条件
-
以
kafka
用户身份登录 Red Hat Enterprise Linux。 - kafka 和 ZooKeeper 正在运行。
- 第 14.2 节 “下载清理控制存档”.
流程
对于 Kafka 集群中的每个代理,一次一个代理:
停止 Kafka 代理:
/opt/kafka/bin/kafka-server-stop.sh
将 Cruise Control Metrics Reporter
.jar
文件复制到 Kafka 库目录中:cp /opt/cruise-control/libs/cruise-control-metrics-reporter-y.y.yyy.redhat-0000x.jar /opt/kafka/libs
在 Kafka 配置文件中(
/opt/kafka/config/server.properties
)配置 Cruise Control Metrics Reporter:将
CruiseControlMetricsReporter
类添加到metric.reporters
配置选项中。不要删除任何现有的指标报告器。metric.reporters=com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
在 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 主题的日志清理策略。
如果需要,配置 SSL。
在 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
。在 Cruise Control 属性文件中(
/opt/cruise-control/config/cruisecontrol.properties
)通过设置相关的客户端配置属性,在 Kafka 代理和 Cruise Control 服务器之间配置 SSL。插入控制从 Kafka 继承 SSL 客户端属性选项,并将这些属性用于所有 Cruise Control 服务器客户端。
重启 Kafka 代理:
/opt/kafka/bin/kafka-server-start.sh
- 为剩余的代理重复第 1-5 步。