AWS Kinesis Consumer Input

1. Sample Configuration

filename            = "kinesis.lua"
ticker_interval     = 5 -- recover from failure but allow it to be captured in the stats

streamName              = "foobar"
-- iteratorType         = "LATEST"
-- credentialProvider   = "INSTANCE"

-- table of AWS Client Configuration settings see:
-- https://sdk.amazonaws.com/cpp/api/LATEST/struct_aws_1_1_client_1_1_client_configuration.html
-- clientConfig         = nil
-- roleArn              = nil

-- Heka message table containing the default header values to use, if they are
-- not populated by the decoder. If 'Fields' is specified it should be in the
-- hashed based format see:  http://mozilla-services.github.io/lua_sandbox/heka/message.html
-- This input will always default the Type header to the specified streamName.
-- default_headers = nil

-- printf_messages = -- see: https://mozilla-services.github.io/lua_sandbox_extensions/lpeg/modules/lpeg/printf.html

-- Specifies a module that will decode the raw data and inject the resulting message.
-- Supports the same syntax as an individual sub decoder
-- see: https://mozilla-services.github.io/lua_sandbox_extensions/lpeg/io_modules/lpeg/sub_decoder_util.html
-- Default:
-- decoder_module = "decoders.heka.framed_protobuf"

source code: kinesis.lua