public KafkaConsumer(KafkaStream<byte[],byte[]> stream){
  _logger.debug("Creating a new stream");
  _stream=stream;
}

public KafkaConsumer ( KafkaStream < byte [ ] , byte [ ] > stream ) { _logger . debug ( "Creating a new stream" ) ; _stream = stream ; }
creates a new consumer object .
