public int getConsumerThreadCount() {
      return config.getInt("systems." + systemName + ".consumer.thread.count", DEFAULT_CONSUMER_THREAD_COUNT);
    }
@return the number of threads to be used for the MockSystemConsumer.
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemFactory.java