分布式消息服务KAFKA版-修改Kafka分区平衡:分区平衡前的准备工作

时间:2024-09-09 17:10:21

分区平衡前的准备工作

  • 在不影响业务的前提下,适当调小Topic老化时间并等待消息老化,减少迁移数据,加快迁移速度,分区平衡任务结束后可重新调整为初始值。修改Topic老化时间的步骤,请参考修改Kafka消息老化时间
  • 确保分区平衡的目标Broker磁盘容量充足,在磁盘存储统计中查看每个Broker的可用磁盘容量。如果目标Broker磁盘剩余容量接近分区平衡迁移到该Broker上的数据量,为了给目标Broker上的消息生产预留存储空间,应先进行磁盘扩容,再进行分区平衡。
support.huaweicloud.com/usermanual-kafka/kafka_ug_0023.html