14.4. 配置和启动控制

流程

1. 编辑 Cruise Control 属性文件 (/opt/cruise-control/config/cruisecontrol.properties)。

2. 配置以下示例配置中显示的属性：

   # The Kafka cluster to control.
   bootstrap.servers=localhost:9092 

   1

   
   
   # The replication factor of Kafka metric sample store topic
   sample.store.topic.replication.factor=2 

   2

   
   
   # The configuration for the BrokerCapacityConfigFileResolver (supports JBOD, non-JBOD, and heterogeneous CPU core capacities)
   #capacity.config.file=config/capacity.json
   #capacity.config.file=config/capacityCores.json
   capacity.config.file=config/capacityJBOD.json 

   3

   
   
   # The list of goals to optimize the Kafka cluster for with pre-computed proposals
   default.goals={List of default optimization goals} 

   4

   
   
   # The list of supported goals
   goals={list of main optimization goals} 

   5

   
   
   # The list of supported hard goals
   hard.goals={List of hard goals} 

   6

   
   
   # How often should the cached proposal be expired and recalculated if necessary
   proposal.expiration.ms=60000 

   7

   
   
   # The zookeeper connect of the Kafka cluster
   zookeeper.connect=localhost:2181 

   8

   Copy to Clipboard Toggle word wrap

   1

   Kafka 代理的主机和端口号（始终端口 9092）。

   2

   Kafka 指标示例存储主题的复制因数。如果您在单节点 Kafka 和 ZooKeeper 集群中评估 Cruise Control，请将此属性设置为 1。对于生产环境，请将此属性设置为 2 或更多。

   3

   为代理资源设置最大容量限制的配置文件。使用应用到 Kafka 部署配置的文件。如需更多信息，请参阅 容量配置。

   4

   使用完全限定域名(FQDN)的逗号分隔列表。许多主要优化目标（请参见 5）已设为默认优化目标；如果需要，您可以添加或删除目标。更多信息请参阅 第 14.5 节 “优化目标概述”。

   5

   使用 FQDN 的逗号分隔列表主要优化目标。要完全排除用于生成优化提议的目标，请从列表中移除它们。更多信息请参阅 第 14.5 节 “优化目标概述”。

   6

   使用 FQDN 的逗号分隔列表。七大主要优化目标已经被设置为硬目标；如果需要，您可以添加或删除目标。更多信息请参阅 第 14.5 节 “优化目标概述”。

   7

   用于刷新默认优化目标的缓存优化建议的时间间隔（毫秒）。更多信息请参阅 第 14.6 节 “优化提议概述”。

   8

   ZooKeeper 连接的主机和端口号（始终端口 2181）。

3. 启动 Cruise Control 服务器。服务器默认在端口 9092 上启动；可选指定不同的端口。

   cd /opt/cruise-control/
   ./kafka-cruise-control-start.sh config/cruisecontrol.properties <port_number>

   Copy to Clipboard Toggle word wrap

4. 要验证 Cruise Control 是否正在运行，将 GET 请求发送到 Cruise Control 服务器的 /state 端点：

   curl 'http://HOST:PORT/kafkacruisecontrol/state'

   Copy to Clipboard Toggle word wrap