Scalable and fault-tolerant data stream processing on multi-core architectures