public interface Checkpoint
Modifier and Type | Method and Description |
---|---|
java.util.Map<SystemStreamPartition,java.lang.String> |
getOffsets()
Gets a unmodifiable view of the last processed offsets for
SystemStreamPartition s. |
short |
getVersion()
Gets the version number of the Checkpoint
|
short getVersion()
java.util.Map<SystemStreamPartition,java.lang.String> getOffsets()
SystemStreamPartition
s.
The returned value differs based on the Checkpoint version:
CheckpointV1
, returns the input SystemStreamPartition
offsets, as well
as the latest KafkaStateChangelogOffset for any store changelog SystemStreamPartition
CheckpointV2
returns the input offsets only.SystemStreamPartition
s.