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

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

    return offsetsAfter;
  }
A simple helper admin class that defines a single partition (partition 0) for
a given system. The metadata uses null for all offsets, which means that the
stream doesn't support offsets, and will be treated as empty. This class
should be used when a system has no concept of partitioning or offsets, since
Samza needs at least one partition for an input stream, in order to read it.
samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java