@Override
  public SystemConsumer getConsumer(String systemName, Config config, MetricsRegistry metricsRegistry) {
    return new ArraySystemConsumer(config);
  }
System factory for the stream from an array
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemFactory.java