updates to kinesis/spark integration