Pipe data to and from AWS Kinesis