public static void main(String[] args) throws Exception {
    SystemProducerBench bench = new SystemProducerBench(args);
    bench.start();
  }
Generic benchmark test for a {@link SystemProducer}.
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemProducerBench.java