Scalable message processing framework for real-time data.