| 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> |
Delegating key/value deserializer that catches exceptions, returning them
in the headers as serialized java objects.
|
| ErrorHandlingDeserializer2<T> | Deprecated
in favor of ErrorHandlingDeserializer
|
| 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. |
| ParseStringDeserializer<T> |
Generic
Deserializer for deserialization of entity from
its String representation received from Kafka (a.k.a parsing). |
| RetryingDeserializer<T> |
A deserialzer configured with a delegate and a
RetryOperations to retry
deserialization in case of transient errors. |
| SerializationUtils |
Utilities for serialization.
|
| StringOrBytesSerializer |
A serializer that can handle
byte[], Bytes and String. |
| ToFromStringSerde<T> |
A Serde that delegates to a
ToStringSerializer and
ParseStringDeserializer. |
| ToStringSerializer<T> |
Generic
Serializer that relies on
Object.toString() to get serialized representation of the entity. |
| Exception | Description |
|---|---|
| DeserializationException |
Exception returned in the consumer record value or key when a deserialization failure
occurs.
|