RecordDeserializationException (clients 8.0.3-ce API)

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.kafka.common.KafkaException

org.apache.kafka.common.errors.SerializationException

org.apache.kafka.common.errors.RecordDeserializationException

All Implemented Interfaces:: Serializable

public class RecordDeserializationExceptionextends SerializationException

This exception is raised for any error that occurs while deserializing records received by the consumer using the configured Deserializer.

See Also:

Nested Class Summary
Nested Classes
Modifier and Type
Class
Description
static enum
RecordDeserializationException.DeserializationExceptionOrigin
Constructor Summary
Constructors
Constructor
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.
Since 3.9.
Method Summary
Modifier and Type
Method
Description
Headers
headers()

ByteBuffer
keyBuffer()

long
offset()

RecordDeserializationException.DeserializationExceptionOrigin
origin()

long
timestamp()

org.apache.kafka.common.record.TimestampType
timestampType()

TopicPartition
topicPartition()

ByteBuffer
valueBuffer()

Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- RecordDeserializationException
  @Deprecatedpublic RecordDeserializationException(TopicPartition partition, long offset, String message, Throwable cause)
  Deprecated.
  Since 3.9. Use RecordDeserializationException(DeserializationExceptionOrigin, TopicPartition, long, long, TimestampType, ByteBuffer, ByteBuffer, Headers, String, Throwable) instead.
- RecordDeserializationException
  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)
Method Details
- origin
  public RecordDeserializationException.DeserializationExceptionOrigin origin()
- topicPartition
  public TopicPartition topicPartition()
- offset
  public long offset()
- timestampType
  public org.apache.kafka.common.record.TimestampType timestampType()
- timestamp
  public long timestamp()
- keyBuffer
  public ByteBuffer keyBuffer()
- valueBuffer
  public ByteBuffer valueBuffer()
- headers
  public Headers headers()