public abstract class PushSession extends Object
Constructor and Description |
---|
PushSession(int leaderEpoch,
long replicaEpoch,
long replicationSessionId,
org.apache.kafka.common.Node replicaNode) |
Modifier and Type | Method and Description |
---|---|
int |
leaderEpoch() |
boolean |
matchesRequestData(long requestReplicaEpoch,
org.apache.kafka.common.message.AppendRecordsRequestData.PartitionData data) |
abstract void |
onAppendRecordsResponse(long logEndOffset,
long logStartOffset)
Called on a successful AppendRecords response for that partition replica.
|
abstract void |
onPushSessionEnded()
Called when the push session has ended.
|
long |
replicaEpoch() |
org.apache.kafka.common.Node |
replicaNode() |
long |
replicationSessionId() |
String |
toString() |
public PushSession(int leaderEpoch, long replicaEpoch, long replicationSessionId, org.apache.kafka.common.Node replicaNode)
public abstract void onAppendRecordsResponse(long logEndOffset, long logStartOffset)
public abstract void onPushSessionEnded()
Called when the push session has ended.
This can happen due to either:
public int leaderEpoch()
public long replicaEpoch()
public long replicationSessionId()
public org.apache.kafka.common.Node replicaNode()
public boolean matchesRequestData(long requestReplicaEpoch, org.apache.kafka.common.message.AppendRecordsRequestData.PartitionData data)