CorruptDataException |
This exception is thrown when we detect corrupt data in the Kafka stream.
|
DataValidationException |
This class encompasses all error conditions which are related to the quality of
the data consumed from Kafka.
|
DuplicateDataException |
|
FatalDataValidationException |
This class encompasses all error conditions which:
1.
|
ImproperlyStartedSegmentException |
|
IncomingDataAfterSegmentEndedException |
This exception is thrown when the server reads data from same segment after the segment is ended.
|
MissingDataException |
This exception is thrown when we detect missing data in the Kafka stream.
|
UnsupportedMessageTypeException |
This is thrown when some code encounters a message type it does not know about.
|