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 KafkaStorageMetadataCorruptionExceptionextends 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:

  • Constructor Details

    • KafkaStorageMetadataCorruptionException

      public KafkaStorageMetadataCorruptionException(Throwable cause)