Package org.apache.kafka.common.errors

Class RecordDeserializationException

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 RecordDeserializationException
extends SerializationException

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

See Also:

• Serialized Form

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

@Deprecated
public 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()