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 Summary

Constructors

Constructor and Description
RecordsPayload(org.apache.kafka.common.record.AbstractRecords records, long appendOffset)

Method Summary

Modifier and Type	Method and Description
long	appendOffset()
org.apache.kafka.common.record.AbstractRecords	records()
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RecordsPayload

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

Method Detail

records

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

appendOffset

public long appendOffset()

toString

public String toString()

Overrides:

toString in class Object