lib/fluent/plugin/out_kinesis_firehose.rb [23:33]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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

    private

    def convert_format(tag, time, record)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



lib/fluent/plugin/out_kinesis_streams.rb [23:33]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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

    private

    def convert_format(tag, time, record)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -