Merge pull request #280 from Shopify/disconnect-bad-broker

Drop the broker if we can't connect to it

producer.go

@@ -372,6 +372,7 @@ func (p *Producer) leaderDispatcher(topic string, partition int32, input chan *M
 		}
 
 		if _, err = leader.Connected(); err != nil {
+			p.client.disconnectBroker(leader)
 			return err
 		}