Package io.confluent.kafka.replication.push.buffer

Class PushReplicationEvent.RecordsPayload

java.lang.Object
io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload
Enclosing class:
PushReplicationEvent<T>
public static class PushReplicationEvent.RecordsPayload extends Object
A payload carrying an AbstractRecords representing some records already appended on the partition replica leader, their append offset, and the high watermark value at the time of creating the records. Used by PushReplicationEvent.Type.MEMORY_RECORDS events.

  • Constructor Details

    • RecordsPayload

      public RecordsPayload(org.apache.kafka.common.record.AbstractRecords records, long appendOffset)

  • Method Details

    • records

      public org.apache.kafka.common.record.AbstractRecords records()

    • appendOffset

      public long appendOffset()

    • toString

      public String toString()
      Overrides:
      toString in class Object