Monitoring of real-time data pipelines