Package org.apache.kafka.common.errors

Class KafkaStorageException

  • All Implemented Interfaces:
    java.io.Serializable
    public class KafkaStorageException
extends InvalidMetadataException
    Miscellaneous disk-related IOException occurred when handling a request. Client should request metadata update and retry if the response shows KafkaStorageException Here are the guidelines on how to handle KafkaStorageException and IOException: 1) If the server has not finished loading logs, IOException does not need to be converted to KafkaStorageException 2) After the server has finished loading logs, IOException should be caught and trigger LogDirFailureChannel.maybeAddOfflineLogDir() Then the IOException should either be swallowed and logged, or be converted and re-thrown as KafkaStorageException 3) It is preferred for IOException to be caught in Log rather than in ReplicaManager or LogSegment.
    See Also:
    Serialized Form

    • Method Summary

      • Methods inherited from class java.lang.Throwable

        addSuppressed, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Constructor Detail

      • KafkaStorageException

        public KafkaStorageException()

      • KafkaStorageException

        public KafkaStorageException​(java.lang.String message)

      • KafkaStorageException

        public KafkaStorageException​(java.lang.Throwable cause)

      • KafkaStorageException

        public KafkaStorageException​(java.lang.String message,
                             java.lang.Throwable cause)