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 DeserializationExceptionListenerUtils.byteArrayToDeserializationException(LogAccessor logger, byte[] value) Deprecated.static DeserializationExceptionListenerUtils.getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String headerName, LogAccessor logger) Deprecated. -
Uses of DeserializationException in org.springframework.kafka.requestreply
Methods in org.springframework.kafka.requestreply that return DeserializationExceptionModifier and TypeMethodDescriptionstatic DeserializationExceptionReplyingKafkaTemplate.checkDeserialization(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, LogAccessor logger) Return aDeserializationExceptionif either the key or value failed deserialization; null otherwise. -
Uses of DeserializationException in org.springframework.kafka.support.serializer
Methods in org.springframework.kafka.support.serializer that return DeserializationExceptionModifier and TypeMethodDescriptionstatic DeserializationExceptionSerializationUtils.byteArrayToDeserializationException(LogAccessor logger, org.apache.kafka.common.header.Header header) Convert a byte array containing a serializedDeserializationExceptionto theDeserializationException.static DeserializationExceptionSerializationUtils.getExceptionFromHeader(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, String headerName, LogAccessor logger) Extract aDeserializationExceptionfrom the supplied header name, if present.
SerializationUtils.getExceptionFromHeader(ConsumerRecord, String, LogAccessor)orSerializationUtils.byteArrayToDeserializationException(LogAccessor, org.apache.kafka.common.header.Header).