Exception: Fluent::Plugin::KinesisOutput::InvalidRecordError

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

Instance Method Summary collapse

Methods inherited from SkipRecordError

#to_s

Constructor Details

#initialize(record) ⇒ InvalidRecordError

Returns a new instance of InvalidRecordError.



53
54
55
# File 'lib/fluent/plugin/kinesis.rb', line 53

def initialize(record)
  super "Invalid type of record", record
end