Real-time pricing engine processing 2M+ events per day
Challenge
The client's pricing system ran on batch jobs every 45 seconds — too slow to react to demand signals during peak hours, causing lost margin and inventory imbalance.
What we did
We designed a streaming pipeline using Kafka and Flink, replacing the batch layer with event-driven processing. A new pricing service consumed signals in real time and published prices to a Redis cache consumed by the product catalog.
Outcomes
- Pricing latency dropped from 45s to under 200ms
- 12% improvement in gross margin during peak windows
- Pipeline now handles 2M+ events/day with headroom to 10M