Class: Fluent::KinesisFirehoseOutput

Inherits:

BufferedOutput

Object
BufferedOutput
Fluent::KinesisFirehoseOutput

Includes:: KinesisHelper

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

Instance Method Summary collapse

#write(chunk) ⇒ Object

Methods included from KinesisHelper

Methods included from Fluent::KinesisHelper::Initialize

Instance Method Details

#write(chunk) ⇒ `Object`

# File 'lib/fluent/plugin/out_kinesis_firehose.rb', line 23

def write(chunk)
  records = convert_to_records(chunk)
  split_to_batches(records).each do |batch|
    batch_request_with_retry(batch)
  end
  log.debug("Written #{records.size} records")
end