Added unit test for consumer stream
Added unit test for consumer stream

eclub-sense/zetta,zettajs/zetta,Vam85/zetta,DhruvKumar/zetta,kyork-cl/zetta,kyork-cl/zetta,eclub-sense/zetta,zettajs/zetta,eclub-sense/zetta2.0-runtime,DhruvKumar/zetta,Vam85/zetta,eclub-sense/zetta2.0-runtime