@Override
      public Map<SystemStreamPartition, String> getOffsetsAfter(Map<SystemStreamPartition, String> offsets) {
        return null;
      }
A mock system backed by a set of in-memory queues. Used for testing w/o actual external messaging systems.
samza-core/src/test/java/org/apache/samza/system/MockSystemFactory.java