| DelegatingByTopicDeserializer |
A Deserializer that delegates to other deserializers based on the topic name.
|
| DelegatingByTopicSerialization<T extends java.io.Closeable> |
Base class with common code for delegating by topic serialization.
|
| DelegatingByTopicSerializer |
A Serializer that delegates to other serializers based on a topic pattern.
|
| DelegatingByTypeSerializer |
Delegates to a serializer based on type.
|
| 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.
|
| 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> |
|
| ToStringSerializer<T> |
Generic Serializer that relies on
Object.toString() to get serialized representation of the entity.
|