Transport Infra · Real-time Processing

Electronic Toll
Management System

High-volume toll operations

Real-time toll transaction processing integrating FASTag, ANPR cameras, vehicle sensors, lane devices, and bank APIs. Rebuilt from synchronous to Kafka event-driven with zero data loss.

20x
Throughput increase
150ms
Processing (from 5s)
12K
Events/sec peak
0
Data loss events
The transformation

From synchronous bottleneck to event-driven throughput

  • Processing time: ~3–5 seconds reduced to ~150–300 ms
  • Throughput: ~500–800 events/sec scaled to ~8,000–12,000 events/sec
  • Kafka-based buffering with zero data loss for all financial transactions
  • FASTag, ANPR, vehicle sensor, and bank API integration
  • Event-driven architecture replacing brittle synchronous chain
  • Handles peak seasonal traffic without queue saturation or data loss
Architecture Diagram

Kafka-driven real-time toll event processing

Physical lane devices feed FASTag, ANPR, sensor, and bank events into a Kafka pipeline. Event-driven consumers handle payment, audit, and settlement, processing 12,000 events/sec with zero data loss.

Architecture diagram: Electronic toll management system PHYSICAL LANE DEVICES 📡 FASTag Reader RFID scan Vehicle ID + tag 📷 ANPR Camera Plate recognition Vehicle class ⚖️ Vehicle Sensors Weight · axle count Speed detection 🚦 Lane Devices Boom gate · LED Display board 🏦 Bank APIs FASTag balance Debit · confirm EVENT INGESTION EVENT COLLECTOR: Lane Edge Service Aggregates all device events · Assigns transaction ID · Timestamps · Publishes to Kafka KAFKA PROCESSING PIPELINE APACHE KAFKA: Event Stream Processing toll-events topic 12K events/sec peak payment-events topic Financial transactions dlq topic Dead letter queue Zero data loss Buffered durably SETTLEMENT & REPORTING Payment Consumer FASTag debit via bank API · ~150ms Audit Consumer Every event logged Idempotent writes MariaDB Transaction records Settlement data Dashboard + Reports Real-time throughput Settlement reports Before: ~5s processing · ~800 events/sec → After: ~150ms · 12,000 events/sec · Zero data loss
Tech stack

Production-grade engineering stack

Apache KafkaMariaDBHybrid infraFASTag integrationANPREvent-driven

Ready to build something similar?

Let’s discuss your requirements, architecture, and compliance needs.

Start a conversationSee all case studies