Мой кластер 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 репликами, и я могу писать / читать из новой темы.Когда я пытался читать / писать старые темы в командной строке, иногда хорошо, а иногда не получалось.
Я также пытался создать файл / папку на диске, это тоже было нормально.Поэтому я запутался, почему Кафка выбросил исключение ошибки диска.