OffsetTrackingBatchLogReader.OffsetTrackingObserveHandle

All Superinterfaces:

java.lang.AutoCloseable, ObserveHandle

Enclosing class:

OffsetTrackingBatchLogReader
```
public static interface OffsetTrackingBatchLogReader.OffsetTrackingObserveHandle
extends ObserveHandle
```
Batch observe handle, that has access to consumed offsets.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  java.util.List<Offset> getCurrentOffsets()
  Get consumed offset.
  - Methods inherited from interface cz.o2.proxima.direct.core.batch.ObserveHandle
    close, disableRateLimiting, isReadyForProcessing

- Method Detail
  - getCurrentOffsets
```
java.util.List<Offset> getCurrentOffsets()
```
    Get consumed offset. Please note, that for offset to be considered as consumed, you must call OffsetTrackingBatchLogReader.OffsetCommitter.markOffsetAsConsumed() first.
    
    Returns:
    
    List of consumed offsets.