Uses of Class
org.springframework.kafka.support.serializer.DeserializationException
Packages that use DeserializationException
Package
Description
Package for kafka listeners
Provides classes for request/reply semantics.
-
Uses of DeserializationException in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return DeserializationExceptionModifier and TypeMethodDescriptionstatic DeserializationException
ListenerUtils.byteArrayToDeserializationException
(LogAccessor logger, byte[] value) Convert a byte array containing a serializedDeserializationException
to theDeserializationException
.static DeserializationException
ListenerUtils.getExceptionFromHeader
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String headerName, LogAccessor logger) Extract aDeserializationException
from the supplied header name, if present. -
Uses of DeserializationException in org.springframework.kafka.requestreply
Methods in org.springframework.kafka.requestreply that return DeserializationExceptionModifier and TypeMethodDescriptionstatic DeserializationException
ReplyingKafkaTemplate.checkDeserialization
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, LogAccessor logger) Return aDeserializationException
if either the key or value failed deserialization; null otherwise.