Package org.springframework.kafka.support.serializer

Class FailedDeserializationInfo

java.lang.Object

org.springframework.kafka.support.serializer.FailedDeserializationInfo

public class FailedDeserializationInfo
extends 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	Description
FailedDeserializationInfo(String topic, org.apache.kafka.common.header.Headers headers, byte[] data, boolean isForKey, Exception exception)	Construct an instance with the contextual information.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

FailedDeserializationInfo

public FailedDeserializationInfo(String topic,
 org.apache.kafka.common.header.Headers headers,
 byte[] data,
 boolean isForKey,
 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 Details

getTopic

public String getTopic()

getHeaders

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

getData

public byte[] getData()

isForKey

public boolean isForKey()

getException

public Exception getException()

toString

public String toString()

Overrides:

toString in class Object