[SPARK-1981] Add AWS Kinesis streaming support

i removed this helper method as it is only used in 1 place.  

this is passed in to KinesisRecordProcessor from the KinesisReceiver.  it's exposed for testability/mockability as demonstrated in the KinesisReceiverSuite of Scala tests. (ie. lines 81, 83, 86)