| Class | Description |
|---|---|
| DelegatingDeserializer |
A
Deserializer that delegates to other deserializers based on a serialization
selector header. |
| DelegatingSerializer |
A
Serializer that delegates to other serializers based on a serialization
selector header. |
| ErrorHandlingDeserializer<T> | Deprecated
in favor of
ErrorHandlingDeserializer2. |
| ErrorHandlingDeserializer2<T> |
Delegating key/value deserializer that catches exceptions, returning them
in the headers as serialized java objects.
|
| FailedDeserializationInfo |
Class containing all the contextual information around a deserialization error.
|
| 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. |
| RetryingDeserializer<T> |
A deserialzer configured with a delegate and a
RetryOperations to retry
deserialization in case of transient errors. |
| StringOrBytesSerializer |
A serializer that can handle
byte[], Bytes and String. |
| Exception | Description |
|---|---|
| DeserializationException |
Exception returned in the consumer record value or key when a deserialization failure
occurs.
|