You are a Machine Learning Engineer at a social media company that needs to process and analyze real-time data streams from user interactions to provide personalized content recommendations. The company uses Amazon Kinesis to handle the data streams. Which combination of Amazon Kinesis features should you use to build an efficient and scalable real-time data processing pipeline for this use case? (Select two)