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:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description KafkaStorageException()KafkaStorageException(String message)KafkaStorageException(String message, Throwable cause)KafkaStorageException(Throwable cause)
-
Method Summary
-
Methods inherited from class org.apache.kafka.common.errors.ApiException
fillInStackTrace
-
Methods inherited from class java.lang.Throwable
addSuppressed, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
-