You are designing a stream processing solution that must handle high volumes of data from social media feeds. The solution needs to scale resources dynamically based on the incoming data rate. Which approach would you take to ensure efficient scaling, and how would you configure the system to handle upserts (updates and inserts) efficiently?