public static class DeserializationErrorHandlingJsonSerde.DeserializationError extends Object
Constructor and Description |
---|
DeserializationError(org.apache.kafka.common.header.Headers headers,
byte[] data,
boolean isForKey,
Exception exception) |
Modifier and Type | Method and Description |
---|---|
byte[] |
getData() |
Exception |
getException() |
org.apache.kafka.common.header.Headers |
getHeaders() |
boolean |
isForKey() |
String |
toString() |
public DeserializationError(org.apache.kafka.common.header.Headers headers, byte[] data, boolean isForKey, Exception exception)