For a telco customer I contributed to the development of a real time radio towers’ kpi monitoring application using Spark and Scala. The application main goal is to process a big amount of data to check if some quality threshold has been exceeded and to raise an alarm. Using Cats to implement the validation logic and functional error handling of the configuration companion microservice has been the most intriguing challenge.

I built a POC using Kafka Streams Scala API to monitor and process in real time events polled from WebSocket channel using Akka HTTP to produce aggregated information and metrics.