KafkaConnection now uses BinaryReader to be sure that all data from stre...

...am is read.  Consumer will retry if message is not possible to add to fetchResponseQueue.
When the program starts now, it will return all previous messages - not just some of them.