本申请实施例提出了一种针对kafka集群的磁盘保护方法及相关设备，其中，上述磁盘保护方法中，轮询kafka集群中所有存储服务器的磁盘容量；当任一存储服务器的磁盘容量达到保护阈值时，获取分区分布信息，对每一个存储服务器，查询所述存储服务器的数据目录，按照占用空间由大到小的顺序找出第一预设数量的段文件；对每一个段文件，获取所述段文件所属的主题及分区，依据所述分布信息判断所述段文件所属的分区是否为主分区；当所述段文件所属的分区为主分区，按照预设比例清理所述段文件所属的分区下的段文件，从而保证了磁盘的可用容量，从而使得kafka系统在出现突发流量时，磁盘空间不会出现过载问题，保证了kafka服务的高可用。