This implements infinite retry. Beats must be allowed to drop events.  Calling `r.batch.RetryEvents` will return the failed events within the batch to libbeat. libbeat decides wether to drop or retry.