public class FailedDeserializationInfo
extends java.lang.Object
| 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.
|
| 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() |
public FailedDeserializationInfo(java.lang.String topic,
org.apache.kafka.common.header.Headers headers,
byte[] data,
boolean isForKey,
java.lang.Exception exception)
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.public java.lang.String getTopic()
public org.apache.kafka.common.header.Headers getHeaders()
public byte[] getData()
public boolean isForKey()
public java.lang.Exception getException()
public java.lang.String toString()
toString in class java.lang.Object