Connection management first cut
+ Implemented separate connection channel for broker agnostic commands
+ Implemented connection mapping for topic/partition combo
+ Connection recovery using logic defined in the Kafka 0.8 protocol