A system and method for data stream processing. Two or more instances are connected as a topology, wherein at least one of the instances is a spout and at least one is a bolt. The topology is submitted to a scheduler which receives resource offers from a cluster.