implement a real-time data processing pipelines with kinesis