io.confluent.kafka.replication.push.buffer

Class PushReplicationEvent.TransitionRecordsPayload

java.lang.Object

io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload

io.confluent.kafka.replication.push.buffer.PushReplicationEvent.TransitionRecordsPayload

Enclosing class:

PushReplicationEvent<T>

public static final class PushReplicationEvent.TransitionRecordsPayload
extends PushReplicationEvent.RecordsPayload

Constructor Summary

Constructors

Constructor and Description
TransitionRecordsPayload(PushReplicationEvent.RecordsPayload payload, CompletableFuture<Void> startFuture)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	startFuture()
String	toString()

Methods inherited from class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload

appendOffset, highWatermark, records

Methods inherited from class java.lang.Object

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

Constructor Detail

TransitionRecordsPayload

public TransitionRecordsPayload(PushReplicationEvent.RecordsPayload payload,
                                CompletableFuture<Void> startFuture)

Method Detail

startFuture

public CompletableFuture<Void> startFuture()

toString

public String toString()

Overrides:

toString in class PushReplicationEvent.RecordsPayload