修改分区平衡

操作场景

分区平衡是指将分区的副本重新分配到不同的代理上，解决代理负载不均衡问题。

需要进行分区平衡的场景如下：

• 实例扩容代理个数后，将原有Topic分区的副本迁移到新代理上
• 将高负载代理上的Leader分区切换为Follower
• 增加/减少副本数量

分布式消息服务Kafka版控制台提供两种分区平衡的方法：自动平衡和手动平衡，建议选择自动平衡，确保分区Leader的均匀分布。

单机版实例不支持分区平衡。

操作影响

• 对数据量大的Topic进行分区平衡，会占用大量的网络和存储带宽，业务可能会出现请求超时或者时延增大，建议在业务低峰期时操作。对Topic进行分区平衡前，根据Kafka实例规格对比当前实例负载情况，评估是否可以进行分区平衡，建议预留足够的带宽进行分区平衡，CPU使用率在90%以上时，不建议进行分区平衡。
• 带宽限制是指设定Topic进行副本同步的带宽上限，确保不会对该实例上的其他Topic造成流量冲击。但需要注意，带宽限制不会区分是正常的生产消息造成的副本同步还是分区平衡造成的副本同步，如果带宽限制设定过小，可能会影响正常的生产消息，且可能会造成分区平衡一直无法结束。
• 分区平衡任务启动后，不能删除正在进行分区平衡的Topic，否则会导致分区平衡任务无法结束。
• 分区平衡任务启动后，无法修改Topic的分区数。
• 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。
• 已设置了一个定时分区平衡任务，在此任务未执行前，无法执行其他分区平衡任务。
• 分区平衡后Topic的metadata会改变，如果生产者不支持重试机制，会有少量的请求失败，导致部分消息生产失败。
• 数据量大的Topic进行分区平衡的时间会比较长，建议根据Topic的消费情况，适当调小Topic老化时间，使得Topic的部分历史数据被及时清理，加快迁移速度。

分区平衡前的准备工作

• 在不影响业务的前提下，适当调小Topic老化时间并等待消息老化，减少迁移数据，加快迁移速度，分区平衡任务结束后可重新调整为初始值。
• 确保分区平衡的目标Broker磁盘容量充足。如果目标Broker磁盘剩余容量接近分区平衡迁移到该Broker上的数据量，为了给目标Broker上的消息生产预留存储空间，应先进行磁盘扩容，再进行分区平衡。

自动平衡

1. 登录管理控制台。
2. 在管理控制台左上角单击，选择区域。
   

   请选择Kafka实例所在的区域。

3. 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
4. 单击Kafka实例的名称，进入实例详情页面。
5. 在左侧导航栏单击“Topic管理”，进入Topic列表页面。
6. 通过以下任意一种方法，修改分区平衡。
   • 勾选Topic名称左侧的方框，可选一个或多个，单击信息栏左上侧的“一键平衡 > 自动平衡”。
   • 在待修改分区平衡的Topic所在行，单击“更多 > 一键平衡 > 自动平衡”。

7. 设置自动平衡参数。
   • 在“Brokers列表”区域，勾选目标Broker的名称，Topic分区的副本即将迁移至目标Broker上。
   • 在“Topic列表”区域，输入Topic需要自动平衡的副本数，副本数须小于等于Broker的数量。
   • 在“带宽限制”中，输入带宽大小，默认值为“-1”，表示不限制带宽。如果实例负载较低，建议不设置带宽限制。如果需要设置带宽限制，建议该参数值不小于待分区平衡Topic的总生产带宽 * 待分区平衡Topic的最大副本数。带宽限制值的估算方法，请参考带宽限制值估算方法。
   • 在“执行时间”中，选择分区平衡任务执行的时间。“立即执行”表示立即执行分区平衡任务。“定时执行”表示在指定的时间执行分区平衡任务。
   图1 设置自动平衡参数
   

8. （可选）单击“一键测算”，在“预估耗时”中，显示执行自动平衡大概需要的时间。
9. 单击“确定”，自动跳转到Topic列表页面。

   在Topic列表页面左上方单击“查看变更任务”，进入“后台任务管理”页面，查看分区平衡任务的状态。

   • 非定时分区平衡任务：在“后台任务管理”页面的右上角选择“后台任务”，当非定时分区平衡任务的“状态”为“成功”时，表示分区平衡完成。
   • 定时分区平衡任务：在“后台任务管理”页面的右上角选择“定时任务”，当“状态”为“待执行”时，表示定时分区平衡任务未执行。当“状态”为“成功”时，表示定时分区平衡任务开始执行。在页面右上角选择“后台任务”，当定时分区平衡任务的“状态”为“成功”时，表示分区平衡完成。
   图2 后台任务管理页面
   
   

   • 分区平衡任务启动后，不能删除正在进行分区平衡的Topic，否则会导致分区平衡任务无法结束。
   • 分区平衡任务启动后，无法修改Topic的分区数。
   • 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。
   • 已设置了一个定时分区平衡任务，在此任务未执行前，无法执行其他分区平衡任务。

手动平衡

1. 登录管理控制台。
2. 在管理控制台左上角单击，选择区域。
   

   请选择Kafka实例所在的区域。

3. 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
4. 单击Kafka实例的名称，进入实例详情页面。
5. 在左侧导航栏单击“Topic管理”，进入Topic列表页面。
6. 通过以下任意一种方法，修改分区平衡。
   • 勾选Topic名称左侧的方框，手动平衡每次只能勾选一个Topic，单击信息栏左上侧的“一键平衡 > 手动平衡”。
   • 在待修改分区平衡的Topic所在行，单击“更多 > 一键平衡 > 手动平衡”。

7. 设置手动平衡参数。
   • 在“手动平衡”对话框右上角，单击“减少副本”/“添加副本”，为Topic的每个分区减少/增加副本数。
   • 在待修改分区平衡的副本名称下，单击Broker名称或，选择目标Broker的名称，副本即将迁移至目标Broker上。同一分区下的不同副本需要分配在不同的Broker上。
   • 在“带宽限制”中，输入带宽大小，默认值为“-1”，表示不限制带宽。如果实例负载较低，建议不设置带宽限制。如果需要设置带宽限制，建议该参数值不小于待分区平衡Topic的总生产带宽 * 待分区平衡Topic的最大副本数。带宽限制值的估算方法，请参考带宽限制值估算方法。
   • 在“执行时间”中，选择分区平衡任务执行的时间。“立即执行”表示立即执行分区平衡任务。“定时执行”表示在指定的时间执行分区平衡任务。
   图3 设置手动平衡参数
   

8. （可选）单击“一键测算”，在“预估耗时”中，显示执行手动平衡大概需要的时间。
9. 单击“确定”，自动跳转到Topic列表页面。

   在Topic列表页面左上方单击“查看变更任务”，进入“后台任务管理”页面，查看分区平衡任务的状态。

   • 非定时分区平衡任务：在“后台任务管理”页面的右上角选择“后台任务”，当非定时分区平衡任务的“状态”为“成功”时，表示分区平衡完成。
   • 定时分区平衡任务：在“后台任务管理”页面的右上角选择“定时任务”，当“状态”为“待执行”时，表示定时分区平衡任务未执行。当“状态”为“成功”时，表示定时分区平衡任务开始执行。在页面右上角选择“后台任务”，当定时分区平衡任务的“状态”为“成功”时，表示分区平衡完成。
   图4 后台任务管理页面
   
   

   • 分区平衡任务启动后，不能删除正在进行分区平衡的Topic，否则会导致分区平衡任务无法结束。
   • 分区平衡任务启动后，无法修改Topic的分区数。
   • 分区平衡任务启动后，无法手动停止任务，需要等到任务完成。
   • 已设置了一个定时分区平衡任务，在此任务未执行前，无法执行其他分区平衡任务。

修改定时分区平衡任务

1. 在“后台任务管理”页面的右上角选择“定时任务”和时间段，查找待修改的定时分区平衡任务。
   图5 选择“定时任务”和时间段
   

2. 在待修改的定时分区平衡任务后，单击“修改”。
3. 在弹出的“修改定时任务”对话框中，您可以修改定时分区平衡任务的时间，还可以取消定时分区平衡任务，具体操作如下。
   • 修改定时分区平衡任务的时间：修改时间，单击“确定”。
   • 取消定时分区平衡任务：选择“取消”，如图6所示，单击“确定”。
     图6 取消定时分区平衡任务
     

带宽限制值估算方法

带宽限制值受分区平衡任务执行时间、分区副本Leader/Follower分布情况以及消息生产速率等因素影响，具体分析如下。

• 带宽限制值作用范围为整个Broker，对该Broker内所有副本同步的分区进行带宽限流。
• 带宽限制会将分区平衡后新增的副本视为Follower副本限流，分区平衡前的Leader副本视为Leader副本限流，Leader副本的限流和Follower副本限流分开计算。
• 带宽限制不会区分是正常的生产消息造成的副本同步还是分区平衡造成的副本同步，因此两者的流量都会被限流统计。

假设分区平衡任务需要在200s内完成，每个副本的数据量为100MB，在以下几种场景中，估算带宽限制值。

场景一：Topic1有2分区2副本，Topic2有1分区1副本，所有Leader副本在同一个Broker上，Topic1和Topic2分别需要新增1个副本

图7 场景一分区平衡图

如图7所示，有3个副本需要从Broker 0拉取数据，Broker 0中每个副本的数据量为100MB，Broker 0中只有Leader副本，Broker 1和Broker 2中只有Follower副本，由此得出以下数据：

• Broker 0在200s内完成分区平衡所需的带宽限制值=（100+100+100）/200=1.5MB/s
• Broker 1在200s内完成分区平衡所需的带宽限制值=100/200=0.5MB/s
• Broker 2在200s内完成分区平衡所需的带宽限制值=（100+100）/200=1MB/s

综上所述，若想要在200s内完成分区平衡任务，带宽限制值应设为大于等于1.5MB/s。

场景二：Topic1有2分区1副本，Topic2有2分区1副本，Leader副本分布在不同Broker上，Topic1和Topic2分别需要新增1个副本

图8 场景二分区平衡图