@Override
  public SystemProducer getProducer(String systemName, Config config, MetricsRegistry metricsRegistry) {
    // no producer
    return null;
  }
System factory for the stream from an array
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemFactory.java