Exception: Fluent::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.



56
57
58
# File 'lib/fluent/plugin/kinesis.rb', line 56

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