Class KafkaStorageMetadataCorruptionException

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.RefreshRetriableException

org.apache.kafka.common.errors.InvalidMetadataException

org.apache.kafka.common.errors.KafkaStorageMetadataCorruptionException

All Implemented Interfaces:

Serializable

public class KafkaStorageMetadataCorruptionException
extends InvalidMetadataException

Checksum validation of FTPS file fails/(yields IOException) during broker startup. This signifies that either the FTPS file is corrupted or there are disk-related issues. Since corruption could be widespread (potentially affecting log directories), client should trigger LogDirFailureChannel.maybeAddOfflineLogDir()

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
KafkaStorageMetadataCorruptionException(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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

KafkaStorageMetadataCorruptionException

public KafkaStorageMetadataCorruptionException(Throwable cause)