@Override
  public SystemProducer getProducer(String systemName, Config config, MetricsRegistry registry) {
    throw new RuntimeException("MockSystemProducer not implemented.");
  }
MockSystemFactory was built to make performance testing easier.
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemFactory.java