SYNTASA interview question

How would you structure a data pipeline to handle real-time streaming data from multiple sources?