Design and build real-time data processing pipelines to handle continuous data streams.
Set up a local Kafka cluster, write a Python producer to stream simulated sensor data, and a consumer to aggregate metrics in real time.