🚀 Live Streaming Demo
0
Events Processed
0
Events/sec
0
Avg Latency (ms)
🎛️ Stream Producer
Event Rate:
10
events/sec
Event Type:
User Action
Sensor Data
Transaction
Log Entry
System Metric
▶️ Start Stream
⏸️ Stop Stream
🗑️ Clear
Throughput Visualization
📊 Stream Consumer
Latest Events (Real-time)
No events yet. Click "Start Stream" to begin.
🔍 Stream Processing Pipeline
Active Transformations
✅
Filter:
Remove null values and malformed events
✅
Map:
Enrich events with timestamp and metadata
✅
Window:
Tumbling window of 5 seconds for aggregation
✅
Aggregate:
Count events by type, calculate avg latency
✅
Sink:
Write to event stream display and update metrics