Method: Fluent::Plugin::Output#handle_limit_reached

Defined in:
lib/fluent/plugin/output.rb

#handle_limit_reached(error) ⇒ Object 



1355
1356
1357
1358
1359
1360
1361
1362
1363
1364
1365
 
# File 'lib/fluent/plugin/output.rb', line 1355

def handle_limit_reached(error)
  if error
    records = @buffer.queued_records
    msg = "Hit limit for retries. dropping all chunks in the buffer queue."
    log.error msg, retry_times: @retry.steps, records: records, error: error
    log.error_backtrace error.backtrace
  end
  @buffer.clear_queue!
  log.debug "buffer queue cleared"
  @retry = nil
end