new service created for capturing granular data from stream