A distributed real-time data processing system that ingests taxi location streams, processes events with low latency, and pushes live results to a dashboard.
- Focus
- Real-time ingestion and aggregation of high-volume location data with low latency, designed for monitoring moving systems.
- Architecture
- Events are ingested via Kafka, processed in an Apache Storm topology, and key state is stored in Redis for fast access.
- Delivery
- Aggregated results are broadcast to a live dashboard using WebSockets for immediate visual feedback.
- Tech
- Apache Kafka, Apache Storm, Redis, Docker, WebSockets.
- Link
- View on GitHub