KafkaConnection now uses BinaryReader to be sure that all data from stream is read.  Consumer will retry if message is not possible to add to fetchResponseQueue