š¦ššæ:::šš®šÆ š¦ššš±š¶š¼ - Real-time Stream Processing on a Telecoms use case
I just ran a full š§š²š¹š²š°š¼šŗ š”š²ššš¼šæšø š¤šš®š¹š¶šš š š¼š»š¶šš¼šæš¶š»š“ pipeline live inside Str:::Lab Studio - and here's what it looked like.
šŖšµš®š'š šæšš»š»š¶š»š“ š¶š» ššµš¶š š±š²šŗš¼:
A synthetic RAN (Radio Access Network) pipeline - 200 cell towers streaming telemetry at š®š¬š¬ š²šš²š»šš/šš²š° across 6 regions. 9 parallel Flink jobs. 9 Kafka topics. All observable in real time.
š§šµš² š½š¶š½š²š¹š¶š»š² š°š¼šš²šæš:
⢠Tower enrichment - decoding raw integers into regions, tower types, signal quality tiers and SLA classes
⢠1-minute tumbling window KPI aggregation per region
⢠Rolling Signal Quality Index using HOP windows (30s slide / 5min range)
⢠Packet loss + high-latency alert filtering
⢠Handover anomaly detection
⢠SESSION window outage risk scoring (closes after 60s of tower silence)
⢠5-minute capacity planning metrics
⢠SLA breach event scoring
⢠Live continuous SELECT into the Results tab for NOC monitoring
šŖšµš®š šš¼š'šæš² šš²š²š¶š»š“ š¶š» ššµš² ššš:
⢠JVM Heap per job - memory consumption tracked live across all 9 running jobs, showing how each pipeline branch carves out its own heap footprint
⢠Live metric graphs - throughput, backpressure indicators and event rates per pipeline, updating in real time as the datagen floods 200 rec/s through the cluster
⢠Checkpointing metrics - checkpoint duration, size and alignment times for each job with EXACTLY_ONCE mode enabled and state persisted to
/tmp/flink-checkpoints
⢠Job node live events - per-operator stats on the execution graph: records in/out, watermark lag, and busy/idle ratios at the subtask level
All of this running locally. No cloud. No infra setup beyond Docker.
šŖš®š»š šš¼ ššæš š¶š šš¼ššæšš²š¹š³?
The full pipeline SQL is in the repo under example directory. Spin up the stack, paste the queries, and watch your cluster come alive.
ā¢ š£šæš¼š·š²š°š š±š¼š°š:
https://str-lab.io/docs
ā¢ šš¼š°šøš²šæ š¶šŗš®š“š²:
codedstreams/strlabstudio - Docker Image
ā¢ šš¶ššššÆ šæš²š½š¼:
coded-streams/strlabstudio
šš§ šµš©šŖš“ šš°š°š¬š“ š¶š“š¦š§š¶š šµš° šŗš°š¶:
1. Give the repo a star on GitHub - it genuinely helps the project grow
2. Leave a review on docker hub so others can find it.
3. Drop a comment below - questions, feedback, or what pipeline you'd want to run next
More demos coming .š