stream: improved kinesis output error handling

• switched to the exec.BackoffExecutor for retrying kinesis put requests on failed records
• added kinesis_request_id to all request logs for better debugging