anchor.diff:  
   [source,java]
   --------------------------------------------------
  +import org.elasticsearch.action.bulk.BackoffPolicy;
   import org.elasticsearch.action.bulk.BulkProcessor;
   import org.elasticsearch.common.unit.ByteSizeUnit;
   import org.elasticsearch.common.unit.ByteSizeValue;
  
positive.code: <7> We want to flush the bulk every 5 seconds whatever the number of requests
  <8> Set the number of concurrent requests. A value of 0 means that only a single request will  be allowed to be
      executed. A value of 1 means 1 concurrent request is allowed to be executed while accumulating new bulk requests.
  
  Then you can simply add your requests to the `BulkProcessor`:
  
  
negative.code:         .setBulkSize(new ByteSizeValue(1, ByteSizeUnit.GB)) <6>
          .setFlushInterval(TimeValue.timeValueSeconds(5)) <7>
          .setConcurrentRequests(1) <8>
          .setBackoffPolicy(
              BackoffPolicy.exponentialBackoff(TimeValue.timeValueMillis(100), 3)) <9>
          .build();
  --------------------------------------------------
  <1> Add your elasticsearch client
  