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
events.Constructor and Description |
---|
RecordsPayload(org.apache.kafka.common.record.AbstractRecords records,
long appendOffset) |
Modifier and Type | Method and Description |
---|---|
long |
appendOffset() |
org.apache.kafka.common.record.AbstractRecords |
records() |
String |
toString() |