@Override
  public Map<SystemStreamPartition, String> getOffsetsAfter(Map<SystemStreamPartition, String> offsets) {
    Map<SystemStreamPartition, String> offsetsAfter = new HashMap<>();

    for (SystemStreamPartition systemStreamPartition : offsets.keySet()) {
      offsetsAfter.put(systemStreamPartition, null);
    }

    return offsetsAfter;
  }
Source of truth for checkpointing is always kinesis and the offsets written to samza checkpoint topic are ignored.
Hence, return null for the getOffsetsAfter for a supplied map of ssps.
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemAdmin.java