Package org.springframework.kafka.support.serializer
package org.springframework.kafka.support.serializer
-
ClassDescriptionA
Deserializer
that delegates to other deserializers based on the topic name.DelegatingByTopicSerialization<T extends Closeable>Base class with common code for delegating by topic serialization.ASerializer
that delegates to other serializers based on a topic pattern.Delegates to a serializer based on type.ADeserializer
that delegates to other deserializers based on a serialization selector header.ASerializer
that delegates to other serializers based on a serialization selector header.Exception returned in the consumer record value or key when a deserialization failure occurs.Delegating key/value deserializer that catches exceptions, returning them in the headers as serialized java objects.Class containing all the contextual information around a deserialization error.GenericDeserializer
for receiving JSON from Kafka and return Java objects.JsonSerde<T>ASerde
that provides serialization and deserialization in JSON format.GenericSerializer
for sending Java objects to Kafka as JSON.Determine theJavaType
from the topic/data/headers.GenericDeserializer
for deserialization of entity from itsString
representation received from Kafka (a.k.a parsing).A deserializer configured with a delegate and aRetryOperations
to retry deserialization in case of transient errors.Utilities for serialization.A Serde that delegates to aToStringSerializer
andParseStringDeserializer
.GenericSerializer
that relies onObject.toString()
to get serialized representation of the entity.