Adding additional fields for Logstash Kinesis Input

This could help: