better over the wire tcp handling
0.1, Better tests, embedding kafkamocker - an embedded kafka broker

Also better tcp handling, minor tweaks