Package org.nuxeo.lib.stream.log.mem
Class MemLogPartition.OffsetTracker
java.lang.Object
org.nuxeo.lib.stream.log.mem.MemLogPartition.OffsetTracker
- Enclosing class:
- MemLogPartition
Tracks the committed offset for a group.
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
OffsetTracker
public OffsetTracker()
-
-
Method Details
-
get
public long get() -
set
public void set(long offset) -
awaitNanos
- Throws:
InterruptedException
-