@Override
      public Integer offsetComparator(String offset1, String offset2) {
        return offset1.compareTo(offset2);
      }
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