public class DeferredEventQueue extends Object
Constructor and Description |
---|
DeferredEventQueue(org.apache.kafka.common.utils.LogContext logContext) |
Modifier and Type | Method and Description |
---|---|
void |
add(long offset,
DeferredEvent event)
Add a new deferred event to be completed by the provided offset.
|
void |
completeUpTo(long offset)
Complete some purgatory entries.
|
void |
failAll(Exception exception)
Fail all deferred events with the provided exception.
|
OptionalLong |
highestPendingOffset()
Get the offset of the highest pending event, or empty if there are no pending
events.
|
public DeferredEventQueue(org.apache.kafka.common.utils.LogContext logContext)
public void completeUpTo(long offset)
offset
- The offset which the high water mark has advanced to.public void failAll(Exception exception)
exception
- The exception to fail the entries with.public void add(long offset, DeferredEvent event)
offset
- The offset to add the new event at.event
- The new event.public OptionalLong highestPendingOffset()