public int getEventsConsumed() {
      return eventsConsumed.get();
    }
Generic benchmark test for a test consumer but with samza framework
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java