public class DeserializationException extends KafkaException
Constructor and Description |
---|
DeserializationException(java.lang.String message,
byte[] data,
boolean isKey,
java.lang.Throwable cause) |
DeserializationException(java.lang.String message,
org.apache.kafka.common.header.Headers headers,
byte[] data,
boolean isKey,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
byte[] |
getData() |
org.apache.kafka.common.header.Headers |
getHeaders() |
boolean |
isKey() |
void |
setHeaders(org.apache.kafka.common.header.Headers headers) |
contains, getMessage, getMostSpecificCause, getRootCause
public DeserializationException(java.lang.String message, byte[] data, boolean isKey, java.lang.Throwable cause)
public DeserializationException(java.lang.String message, @Nullable org.apache.kafka.common.header.Headers headers, byte[] data, boolean isKey, java.lang.Throwable cause)