14.10. 启动集群重新平衡
如果您对优化建议满意,可以指示 Cruise Control 启动集群重新平衡并开始重新分配分区,如建议中所述。
在生成优化建议和启动集群重新平衡之间尽量少的时间。如果自您生成原始优化建议后经过一段时间,集群状态可能会改变。因此,启动的集群重新平衡可能与您检查的集群不同。若有疑问,首先生成新的优化建议。
次只能有一个集群重新平衡状态为"活动"的。
先决条件
流程
要执行最近生成的优化建议,请使用
dryrun=false
参数向/rebalance
端点发送 POST 请求:curl -X POST 'cruise-control-server:9090/kafkacruisecontrol/rebalance?dryrun=false'
cruise Control 会启动集群重新平衡并返回优化建议。
- 检查优化建议中概述的更改。如果更改不是您预期的,您可以 停止重新平衡。
使用
/user_tasks
端点检查集群重新平衡的进度。正在进行的集群重新平衡状态为"活动"。查看在 Cruise Control 服务器中执行的所有集群重新平衡任务:
curl 'cruise-control-server:9090/kafkacruisecontrol/user_tasks' USER TASK ID CLIENT ADDRESS START TIME STATUS REQUEST URL c459316f-9eb5-482f-9d2d-97b5a4cd294d 0:0:0:0:0:0:0:1 2020-06-01_16:10:29 UTC Active POST /kafkacruisecontrol/rebalance?dryrun=false 445e2fc3-6531-4243-b0a6-36ef7c5059b4 0:0:0:0:0:0:0:1 2020-06-01_14:21:26 UTC Completed GET /kafkacruisecontrol/state?json=true 05c37737-16d1-4e33-8e2b-800dee9f1b01 0:0:0:0:0:0:0:1 2020-06-01_14:36:11 UTC Completed GET /kafkacruisecontrol/state?json=true aebae987-985d-4871-8cfb-6134ecd504ab 0:0:0:0:0:0:0:1 2020-06-01_16:10:04 UTC
要查看特定集群重新平衡任务的状态,请提供
user-task-ids
参数和任务 ID:curl 'cruise-control-server:9090/kafkacruisecontrol/user_tasks?user_task_ids=c459316f-9eb5-482f-9d2d-97b5a4cd294d'