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.
|