added user agent to plugin and updated version number

Author: Brandon Tom

README.md

@@ -69,10 +69,16 @@ At this point any modifications to the plugin code will be applied to this local
 
 You can use the same **2.1** method to run your plugin in an installed Logstash by editing its `Gemfile` and pointing the `:path` to your local plugin development directory or you can build the gem and install it using:
 
+- Install all dependencies of the gem
+```sh
+bundle install
+```
+
 - Build your plugin gem
 ```sh
 gem build logstash-filter-awesome.gemspec
 ```
+
 - Install the plugin from the Logstash home
 ```sh
 bin/plugin install /your/local/plugin/logstash-filter-awesome.gem

lib/logstash/inputs/dynamodb.rb

@@ -49,6 +49,7 @@
 java_import "com.amazonaws.regions.RegionUtils"
 
 module AmazonDynamoDB
+  include_package "com.amazonaws"
   include_package "com.amazonaws.services.dynamodbv2"
   include_package "com.amazonaws.services.dynamodbv2.streamsadapter"
   include_package "com.amazonaws.services.dynamodbv2.model"
@@ -75,6 +76,8 @@ module KCL
 class LogStash::Inputs::DynamoDB < LogStash::Inputs::Base
   config_name "dynamodb"
 
+  USER_AGENT = " logstash-input-dynamodb/1.0.0".freeze
+
   LF_DYNAMODB = "dymamodb".freeze
   LF_JSON_NO_BIN = "json_drop_binary".freeze
   LF_PLAIN = "plain".freeze
@@ -170,7 +173,9 @@ def register
     end
 
     #Create DynamoDB Client
-    @dynamodb_client = AmazonDynamoDB::AmazonDynamoDBClient.new(@credentials)
+    @client_configuration = AmazonDynamoDB::ClientConfiguration.new()
+    @client_configuration.setUserAgent(@client_configuration.getUserAgent() + USER_AGENT)
+    @dynamodb_client = AmazonDynamoDB::AmazonDynamoDBClient.new(@credentials, @client_configuration)
 
     @logger.info(@dynamodb_client.to_s)
 
@@ -225,7 +230,7 @@ def setup_stream
     worker_id = SecureRandom.uuid()
     @logger.info("WorkerId: " + worker_id)
 
-    dynamodb_streams_client = AmazonDynamoDB::AmazonDynamoDBStreamsClient.new(@credentials)
+    dynamodb_streams_client = AmazonDynamoDB::AmazonDynamoDBStreamsClient.new(@credentials, @client_configuration)
     adapter = Java::ComAmazonawsServicesDynamodbv2Streamsadapter::AmazonDynamoDBStreamsAdapterClient.new(@credentials)
     if not @streams_endpoint.nil?
       adapter.setEndpoint(@streams_endpoint)

logstash-input-dynamodb.gemspec

@@ -1,12 +1,12 @@
 Gem::Specification.new do |s|
   s.name = 'logstash-input-dynamodb'
-  s.version         = '0.1.0'
+  s.version = '1.0.0'
   s.licenses = ['Apache License (2.0)']
   s.summary = "This input plugin scans a specified DynamoDB table and then reads changes to a DynamoDB table from the associated DynamoDB Stream."
   s.description = "This gem is a logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/plugin install gemname. This gem is not a stand-alone program"
   s.authors = ["Amazon"]
   s.email = '[email protected]'
-  #s.homepage = "[GITHUB/awslabs]"
+  s.homepage = "https://github.com/logstash-plugins/logstash-input-dynamodb"
   s.require_paths = ["lib"]
 
   # Files