public static class PushReplicationEvent.RecordsPayload extends Object
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
and PushReplicationEvent.Type.FILE_RECORDS
events.Constructor and Description |
---|
RecordsPayload(org.apache.kafka.common.record.AbstractRecords records,
long appendOffset,
long highWatermark) |
Modifier and Type | Method and Description |
---|---|
long |
appendOffset() |
long |
highWatermark() |
org.apache.kafka.common.record.AbstractRecords |
records() |
String |
toString() |