Class DataValidationException

All Implemented Interfaces:
Serializable
Direct Known Subclasses:
DuplicateDataException, FatalDataValidationException

public abstract class DataValidationException extends KafkaConsumerException
This class encompasses all error conditions which are related to the quality of the data consumed from Kafka. Some of these exceptions represent unrecoverable conditions, while others may be benign.
See Also:
  • Constructor Details

    • DataValidationException

      public DataValidationException(String message)
    • DataValidationException

      public DataValidationException(String message, Throwable throwable)