public class RecordDeserializationException extends SerializationException
Deserializer.| Modifier and Type | Class and Description |
|---|---|
static class | RecordDeserializationException.DeserializationExceptionOrigin |
| Constructor and Description |
|---|
RecordDeserializationException(RecordDeserializationException.DeserializationExceptionOrigin origin, TopicPartition partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, ByteBuffer keyBuffer, ByteBuffer valueBuffer, Headers headers, String message, Throwable cause) |
RecordDeserializationException(TopicPartition partition, long offset, String message, Throwable cause)Deprecated. |
| Modifier and Type | Method and Description |
|---|---|
Headers | headers() |
ByteBuffer | keyBuffer() |
long | offset() |
RecordDeserializationException.DeserializationExceptionOrigin | origin() |
long | timestamp() |
org.apache.kafka.common.record.TimestampType | timestampType() |
TopicPartition | topicPartition() |
ByteBuffer | valueBuffer() |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString@Deprecated public RecordDeserializationException(TopicPartition partition, long offset, String message, Throwable cause)
public RecordDeserializationException(RecordDeserializationException.DeserializationExceptionOrigin origin, TopicPartition partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, ByteBuffer keyBuffer, ByteBuffer valueBuffer, Headers headers, String message, Throwable cause)
public RecordDeserializationException.DeserializationExceptionOrigin origin()
public TopicPartition topicPartition()
public long offset()
public org.apache.kafka.common.record.TimestampType timestampType()
public long timestamp()
public ByteBuffer keyBuffer()
public ByteBuffer valueBuffer()
public Headers headers()