Added unit test for consumer stream