Exception: Fluent::KinesisOutput::SkipRecordError

Inherits:
StandardError
  • Object
show all
Defined in:
lib/fluent/plugin/kinesis.rb

Instance Method Summary collapse

Constructor Details

#initialize(message, record) ⇒ SkipRecordError

Returns a new instance of SkipRecordError.



32
33
34
35
36
37
38
39
# File 'lib/fluent/plugin/kinesis.rb', line 32

def initialize(message, record)
  super message
  @record_message = if record.is_a? Array
    record.reverse.map(&:to_s).join(', ')
  else
    record.to_s
  end
end

Instance Method Details

#to_sObject



41
42
43
# File 'lib/fluent/plugin/kinesis.rb', line 41

def to_s
  super + ": " + @record_message
end