Package org.apache.kafka.common.errors

Class KafkaStorageException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.common.errors.ApiException
org.apache.kafka.common.errors.RetriableException
org.apache.kafka.common.errors.InvalidMetadataException
org.apache.kafka.common.errors.KafkaStorageException
All Implemented Interfaces:
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:

  • Constructor Details

    • KafkaStorageException

      public KafkaStorageException()

    • KafkaStorageException

      public KafkaStorageException(String message)

    • KafkaStorageException

      public KafkaStorageException(Throwable cause)

    • KafkaStorageException

      public KafkaStorageException(String message, Throwable cause)