Reusable Software Infrastructure For Stream Processing