Merge pull request #162 from PatrickDropbox/master

Fix race condition in producer's Close()

producer.go

@@ -110,6 +110,8 @@ func (p *Producer) Errors() chan error {
 // it may otherwise leak memory. You must call this before calling Close on the
 // underlying client.
 func (p *Producer) Close() error {
+	p.m.RLock()
+	defer p.m.RUnlock()
 	for _, bp := range p.brokerProducers {
 		bp.Close()
 	}