Class | Description |
---|---|
ErrorHandlingDeserializer |
Delegating key/value deserializer that catches exceptions, returning them
in the consumer record.
|
JsonDeserializer<T> |
Generic
Deserializer for receiving JSON from Kafka and return Java objects. |
JsonSerde<T> |
A
Serde that provides serialization and
deserialization in JSON format. |
JsonSerializer<T> |
Generic
Serializer for sending Java objects to Kafka as JSON. |
Exception | Description |
---|---|
DeserializationException |
Exception returned in the consumer record value or key when a deserialization failure
occurs.
|