org.springframework.kafka.support.serializer

Class FailedDeserializationInfo

java.lang.Object

org.springframework.kafka.support.serializer.FailedDeserializationInfo

public class FailedDeserializationInfo
extends java.lang.Object

Class containing all the contextual information around a deserialization error.

Since:

2.2.8

Author:

Victor Perez Rey, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
FailedDeserializationInfo(java.lang.String topic, org.apache.kafka.common.header.Headers headers, byte[] data, boolean isForKey, java.lang.Exception exception) Construct an instance with the contextual information.

Method Summary

Modifier and Type	Method and Description
byte[]	getData()
java.lang.Exception	getException()
org.apache.kafka.common.header.Headers	getHeaders()
java.lang.String	getTopic()
boolean	isForKey()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FailedDeserializationInfo

public FailedDeserializationInfo(java.lang.String topic,
                                 org.apache.kafka.common.header.Headers headers,
                                 byte[] data,
                                 boolean isForKey,
                                 java.lang.Exception exception)

Construct an instance with the contextual information.

Parameters:

topic - topic associated with the data.

headers - headers associated with the record; may be empty.

data - serialized bytes; may be null.

isForKey - true for a key deserializer, false otherwise.

exception - exception causing the deserialization error.

Method Detail

getTopic

public java.lang.String getTopic()

getHeaders

public org.apache.kafka.common.header.Headers getHeaders()

getData

public byte[] getData()

isForKey

public boolean isForKey()

getException

public java.lang.Exception getException()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object