@Override
  public Integer offsetComparator(String offset1, String offset2) {
    return null;
  }
A SystemAdmin that returns a constant set of partitions for all streams.
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java