High Throughput Real-time Stream Processing Framework