First, allow me to share some context: I have an Amazon Kinesis Data Stream, where data is continuously stored. I also have an Apache Flink application that will integrate with the Amazon Kinesis Data Stream and have access to the data in the Amazon Kinesis Data Stream.