aws region config parameter

lib/logstash/inputs/kinesis.rb

@@ -39,6 +39,9 @@ class LogStash::Inputs::Kinesis < LogStash::Inputs::Base
  # The kinesis stream name.
  config :kinesis_stream_name, :validate => :string, :required => true
 
+ # The AWS region for Kinesis, DynamoDB, and CloudWatch (if enabled)
+ config :region, :validate => :string, :default => "us-east-1"
+
  # How many seconds between worker checkpoints to dynamodb.
  config :checkpoint_interval_seconds, :validate => :number, :default => 60
 
@@ -62,7 +65,9 @@ def register
  @application_name,
  @kinesis_stream_name,
  creds,
- worker_id).withInitialPositionInStream(KCL::InitialPositionInStream::TRIM_HORIZON)
+ worker_id).
+ withInitialPositionInStream(KCL::InitialPositionInStream::TRIM_HORIZON).
+ withRegionName(@region)
  end
 
  def run(output_queue)

lib/logstash/inputs/kinesis/version.rb

@@ -1,7 +1,7 @@
 module Logstash
  module Input
  module Kinesis
- VERSION = "1.2.1"
+ VERSION = "1.2.2"
  end
  end
 end

spec/inputs/kinesis_spec.rb

@@ -19,6 +19,7 @@ def run
  "codec" => codec,
  "metrics" => metrics,
  "checkpoint_interval_seconds" => 120,
+ "region" => "ap-southeast-1",
  }}
 
  subject!(:kinesis) { LogStash::Inputs::Kinesis.new(config, kcl_class) }
@@ -35,6 +36,7 @@ def run
  kinesis.register
  expect(kinesis.kcl_config.applicationName).to eq("my-processor")
  expect(kinesis.kcl_config.streamName).to eq("run-specs")
+ expect(kinesis.kcl_config.regionName).to eq("ap-southeast-1")
  expect(kinesis.kcl_config.initialPositionInStream).to eq(KCL::InitialPositionInStream::TRIM_HORIZON)
  end