A video streaming platform collects real-time user engagement data, such as play, pause, and skip events, using Amazon Kinesis Data Streams. The platform needs to aggregate this data at 30-second intervals to generate user engagement metrics like total watch time and session durations. The solution must ensure low-latency processing and minimal management overhead. Which of the following options will meet these requirements? (Select two)