package com.amazonaws.kda.flink.starterkit; public enum StreamPosition { LATEST, TRIM_HORIZON, AT_TIMESTAMP }