Uses of Class
org.springframework.kafka.support.serializer.DeserializationException
Package
Description
Package for kafka listeners
Provides classes for request/reply semantics.
-
Uses of DeserializationException in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionstatic DeserializationException
ListenerUtils.byteArrayToDeserializationException
(LogAccessor logger, byte[] value) Deprecated.static DeserializationException
ListenerUtils.getExceptionFromHeader
(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String headerName, LogAccessor logger) Deprecated. -
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.
SerializationUtils.getExceptionFromHeader(ConsumerRecord, String, LogAccessor)
orSerializationUtils.byteArrayToDeserializationException(LogAccessor, org.apache.kafka.common.header.Header)
.