Streaming ETL with Apache Flink and Amazon Kinesis Data Analytics - View it on GitHub