public void register(SystemStreamPartition systemStreamPartition, String offset) {
        MSG_QUEUES.putIfAbsent(systemStreamPartition, new ArrayList<>());
      }
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