
Ultimate access to all questions.
You are tasked with developing a stream processing solution for a smart grid system that monitors and manages energy consumption in real-time. The system needs to detect and respond to anomalies in energy usage patterns. How would you design the solution to achieve this?
A
Use a single centralized processing engine to handle all incoming data, without considering the scalability or fault tolerance.
B
Design a distributed processing architecture that can scale out based on the incoming data volume and detect anomalies using simple threshold-based rules.
C
Implement a machine learning model to detect anomalies in energy usage patterns, but do not consider real-time processing requirements.
D
Design a distributed processing architecture that can scale out based on the incoming data volume and implement a machine learning model to detect anomalies in real-time.