Uses of Class
org.springframework.kafka.support.serializer.DeserializationException
Package
Description
Provides classes for request/reply semantics.
-
Uses of DeserializationException in org.springframework.kafka.requestreply
Modifier 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. -
Uses of DeserializationException in org.springframework.kafka.support.serializer
Modifier and TypeMethodDescriptionstatic DeserializationException
SerializationUtils.byteArrayToDeserializationException
(LogAccessor logger, org.apache.kafka.common.header.Header header) Convert a byte array containing a serializedDeserializationException
to theDeserializationException
.static DeserializationException
SerializationUtils.getExceptionFromHeader
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String headerName, LogAccessor logger) Extract aDeserializationException
from the supplied header name, if present.