public static void main(String[] args) throws Exception {
    SystemConsumerBench bench = new SystemConsumerBench(args);
    bench.start();
  }
Generic benchmark test for a test consumer but with samza framework
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java