Exception: Fluent::KinesisHelper::InvalidRecordError

Inherits:
SkipRecordError show all
Defined in:
lib/fluent/plugin/kinesis_helper/error.rb

Instance Method Summary collapse

Constructor Details

#initialize(record) ⇒ InvalidRecordError

Returns a new instance of InvalidRecordError.



33
34
35
# File 'lib/fluent/plugin/kinesis_helper/error.rb', line 33

def initialize(record)
  super "Invalid type of record: #{record}"
end