code: CompletableFuture<EventPosition> getInitialOffset() {
          return this.hostContext.getCheckpointManager().getCheckpoint(this.partitionId)
                  .thenApply((startingCheckpoint) -> {
                      return checkpointToOffset(startingCheckpoint);
                  }
docs: Returns a String (offset) or Instant (timestamp).