public Optional<Integer> getBulkFlushMaxActions() {
    if (containsKey(CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS)) {
      return Optional.of(getInt(CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS));
    } else {
      return Optional.empty();
    }
  }
Elasticsearch configuration class to read elasticsearch specific configuration from Samza.
samza-elasticsearch/src/main/java/org/apache/samza/config/ElasticsearchConfig.java