我的 Kafka 集群(10 个节点,5 个 zk 节点(突然抛出磁盘错误异常,如下所示:
ERROR [ReplicaFetcher replicaId=196790673,
leaderId=196790680, fetcherId=0]
Error for partition test-topic-23 at offset 1012839
(kafka.server.ReplicaFetcherThread)
org.apache.kafka.common.errors.KafkaStorageException:
Disk error when trying to access log file on the disk
所以我的 Kafka 生产者和消费者失败了,但我仍然可以创建一个具有 36 个分区和 2 个复制品的新主题,并且可以从新主题写入/读取。当我尝试在命令行中读/写旧主题时,有时很好,有时失败。
我还尝试在磁盘上创建一个文件/文件夹,也可以。所以我很困惑为什么卡夫卡抛出磁盘错误异常。
这听起来很明显,但是如果遇到磁盘错误,要检查的主要内容是磁盘。它是否已损坏,或者可能只是一个完整的分区?
另请注意,也许磁盘仍然可以工作一点,或者您可能有多个磁盘,因此像"我仍然可以使用某些磁盘"这样的测试不会提供太多信息。