public abstract class PushSession extends Object
Constructor and Description |
---|
PushSession(int leaderEpoch,
long replicaEpoch,
long replicationSessionId) |
Modifier and Type | Method and Description |
---|---|
int |
leaderEpoch() |
abstract void |
onAppendRecordsResponse(long logEndOffset,
long logStartOffset)
Called on a successful AppendRecords response for that partition replica.
|
abstract void |
onPushSessionEnded()
Called on an unsuccessful AppendRecords response or any other reason for stopping the active
push replication session for that partition replica.
|
long |
replicaEpoch() |
long |
replicationSessionId() |
CompletableFuture<Void> |
startFuture() |
String |
toString() |
public PushSession(int leaderEpoch, long replicaEpoch, long replicationSessionId)
public abstract void onAppendRecordsResponse(long logEndOffset, long logStartOffset)
public abstract void onPushSessionEnded()
public int leaderEpoch()
public long replicaEpoch()
public long replicationSessionId()
public CompletableFuture<Void> startFuture()