##Overview

• This plugin retrieves records from Amazon Kinesis.

• 1 thread is used for each shard; record retrieval occurs in parallel.

• Number of threads is automatically adjusted to match number of shards.

• Sequence numbers from each shard are saved.

• Conforms to default fluent format.

Add this line to your application's Gemfile:

gem 'fluent-plugin-in-kinesis'

And then execute:

$ bundle

Or install it yourself as:

$ gem install fluent-plugin-in-kinesis

##Configuration

Use the word 'kinesis'.

Name of the stream to put data.

AWS access key id.

AWS secret key.

AWS region of your stream. It should be in form like "us-east-1", "us-west-2".

Refer to Regions and Endpoints in AWS General Reference

for supported regions.

Set as needed to specify credentials file.

Name of the stream to put data.

Directory to save sequence number data. Save file will be created in specified directory.

Set if BASE64 decode is necessary.

Set if GZip decompress is necessary.

The maximum number of records to return.

Valid range: Minimum value of 1. Maximum value of 10000.

Frequency of record retrieval.

Value is in seconds.

Frequency of shard state checks.

Value is in seconds.

Parse strings in log. fluentd default parser.

Set to manually specify target Kinesis shards (see below).

Specify the shards to be used (see below).

Max retry count.

##Configuration examples

  type kinesis
  
  stream_name YOUR_STREAM_NAME
  
  aws_key_id YOUR_AWS_ACCESS_KEY
  
  aws_sec_key YOUR_SECRET_KEY

  region ap-northeast-1
  
  load_records_limit 1000
  
  load_shard_interval 10
  
  load_record_interval 2
  
  tag target.log
  
  state_dir_path /tmp/kinesis/save_file
  
  use_base64 true
  
  format json
  
</source>

##Using describe_shard When describe_shard is specified, target shards are manually set using describe_use_shards parameter.

<source>

  type kinesis
  
  stream_name YOUR_STREAM_NAME
  
  aws_key_id YOUR_AWS_ACCESS_KEY
  
  aws_sec_key YOUR_SECRET_KEY

  region ap-northeast-1
  
  load_records_limit 1000
  
  load_shard_interval 10
  
  load_record_interval 2
  
  tag target.log
  
  state_dir_path /tmp/kinesis/save_file
  
  use_base64 true
  
  format json
  
  describe_shard true
  
  describe_use_shards  ["shardId-000000000000", "shardId-000000000002"]
  
</source>

• Amazon Kinesis Developer Guide