Interface Summary Interface Description JsonTypeResolverDetermine the
JavaTypefrom the topic/data/headers.
Class Summary Class Description DelegatingByTopicDeserializerA
Deserializerthat 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. DelegatingByTopicSerializerA
Serializerthat delegates to other serializers based on a topic pattern.
DelegatingByTypeSerializerDelegates to a serializer based on type. DelegatingDeserializerA
Deserializerthat delegates to other deserializers based on a serialization selector header.
Serializerthat 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. FailedDeserializationInfoClass containing all the contextual information around a deserialization error. JsonDeserializer<T>Generic
Deserializerfor receiving JSON from Kafka and return Java objects.
Serdethat provides serialization and deserialization in JSON format.
Serializerfor sending Java objects to Kafka as JSON.
Deserializerfor deserialization of entity from its
Stringrepresentation received from Kafka (a.k.a parsing).
RetryingDeserializer<T>A deserialzer configured with a delegate and a
RetryOperationsto retry deserialization in case of transient errors.
SerializationUtilsUtilities for serialization. StringOrBytesSerializerA serializer that can handle
Serializerthat relies on
Object.toString()to get serialized representation of the entity.
Exception Summary Exception Description DeserializationExceptionException returned in the consumer record value or key when a deserialization failure occurs.