DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class RecordDeserializationException extends SerializationException {
@Deprecated
public RecordDeserializationException(TopicPartition partition,
long offset,
String message,
Throwable cause);
// New constructor
protected RecordDeserializationException(TopicPartition partition,
long offset,
long timestamp,
TimestampType timestampType,
ByteBuffer keyBuffer,
ByteBuffer valueBuffer,
Headers headers,
String message,
Throwable cause);
// New methods
public TimestampType timestampType();
public long timestamp();
public ByteBuffer keyBuffer();
public ByteBuffer valueBuffer();
public byte[] key();
public byte[] value();
public Headers headers();
} |
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class KeyDeserializationException extends RecordDeserializationException {
public KeyDeserializationException(TopicPartition partition,
long offset,
long timestamp,
TimestampType timestampType,
ByteBuffer keyBuffer,
ByteBuffer valueBuffer,
Headers headers,
String message,
Throwable cause);
} |
...