删除Kafka磁盘分区数据
操作场景
Kafka磁盘空间使用率过大时会对性能产生影响,为保证Kafka正常运行,可以删除Topic数据段,释放使用率过高的磁盘。
此删除操作会直接删除磁盘上的数据,请谨慎使用。
约束与限制
该章节操作仅适用于MRS 3.6.0.1及之后版本。
前提条件
已安装Kafka客户端,例如客户端安装目录为“/opt/client”。
操作步骤
- 以客户端安装用户,登录已安装Kafka客户端并且需要删除Topic数据段的节点。
- 切换到Kafka客户端安装目录,例如“/opt/client”。
cd /opt/client
- 执行以下命令,切换到Kafka客户端安装目录。
cd Kafka/kafka
- 使用kafka-clean-disk.sh删除磁盘中的Topic数据。
- 按占用空间大小展示前n个或全部磁盘Topic分区:
bin/kafka-clean-disk.sh --list [n] -d Kafka磁盘目录
例如:
bin/kafka-clean-disk.sh --list 10 -d /srv/BigData/kafka/data1/kafka-logs
- 删除磁盘中Topic分区数据:
bin/kafka-clean-disk.sh -d Kafka磁盘目录 -t 主题名称-分区号 -r 删除数据比率 --force
其中:
- -r:为待删除数据比例,取值范围为0.01~0.99,默认值为0.50。
- --force:为强制删除数据段参数,即使超出目标比例,也会执行删除操作。
- 删除磁盘中Topic分区:
bin/kafka-clean-disk.sh -d Kafka磁盘目录 -T 主题名称 -r 删除数据比率 --force
其中:
- -r:为待删除数据比例,取值范围为0.01~0.99,默认值为0.50。
- --force:为强制删除数据段参数,即使超出目标比例,也会执行删除操作。
- 按占用空间大小展示前n个或全部磁盘Topic分区: