We have done the same, but using WSO2 CEP instead of Esper. Also, one key thing is we have done a layer that accepts queries from the user, partition them using hints from the user, and automatically create and run the Storm topology. Basically, everything come out of the box.