You are developing a new application that will continuously emit JSON data throughout the day. By the end of the year, you expect the application to generate approximately 150 GB of data daily. The system must meet the following requirements: Decouple data producers from consumers Store ingested raw data indefinitely in a cost- and space-efficient way Enable near real-time querying using SQL Retain at least two years of historical data for querying Which data processing pipeline should you implement to satisfy these goals?