public int getConsumerBufferCapacity(String systemName) {
    String bufferCapacity = get(String.format(CONFIG_CONSUMER_BUFFER_CAPACITY, systemName));
    if (bufferCapacity == null) {
      return DEFAULT_CONFIG_CONSUMER_BUFFER_CAPACITY;
    }
    return Integer.parseInt(bufferCapacity);
  }
Get the capacity of the Event Hubs consumer buffer - the blocking queue used for storing messages

@param systemName name of the system
@return int, number of buffered messages per SystemStreamPartition
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java