public int getMessagesPerBatch() {
      return config.getInt("systems." + systemName + ".messages.per.batch", DEFAULT_MESSAGES_PER_BATCH);
    }
@return the messages per batch to be used for the MockSystemConsumer.
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemFactory.java