Design a real-time streaming pipeline for a ride-sharing company that needs to detect surge pricing conditions and alert drivers within seconds. Walk through your architecture and design decisions.

Sample answer preview

Designing a surge pricing detection system requires low-latency processing, accurate spatial and temporal aggregation, and reliable delivery of pricing updates. Here is how I would approach this architecture. Data ingestion uses Kafka as the central event backbone.