Class FatalDataValidationException

All Implemented Interfaces:
Serializable
Direct Known Subclasses:
CorruptDataException, IncomingDataAfterSegmentEndedException, MissingDataException

public abstract class FatalDataValidationException extends DataValidationException
This class encompasses all error conditions which: 1. Are related to the quality of the data consumed from Kafka, and; 2. Are deemed unrecoverable.
See Also:
  • Constructor Details

    • FatalDataValidationException

      public FatalDataValidationException(String message)
    • FatalDataValidationException

      public FatalDataValidationException(String message, Throwable throwable)