Class CorruptDataException

All Implemented Interfaces:
Serializable
Direct Known Subclasses:
UnsupportedMessageTypeException

public class CorruptDataException extends FatalDataValidationException
This exception is thrown when we detect corrupt data in the Kafka stream.
See Also:
  • Constructor Details

    • CorruptDataException

      public CorruptDataException(String message)
    • CorruptDataException

      public CorruptDataException(String message, Throwable throwable)