Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
titleRecordDeserializationException.java
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
languagejava
titleKeyDeserializationException.java
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);
}

...