Producer can not reconnect to broker after server restart

[sunby]

Expected behavior

Producer reconnect to broker after server restart.

Actual behavior

In the current code, I find that if a connection is closed, it will try to stop all producer listeners and consumer handlers registered on it. But if the producer has set the connection to conn and does not register the listener to this connection in

pulsar-client-go/pulsar/producer_partition.go

Lines 264 to 265 in 1df5596

	p._setConn(res.Cnx)
	p._getConn().RegisterListener(p.producerID, p)

. And the connection is closed by another goroutine because of connection.handleSendError

pulsar-client-go/pulsar/internal/connection.go

Line 793 in 1df5596

c.Close()

. The producer can not do reconnectToBroker because no signal will sent to connectClosedCh.

Maybe we should check the result of RegisterListener and call ConnectionClosed by manually?

Steps to reproduce

It's not stable to reproduce

System configuration

Pulsar version: 0.7.0

[sunby]

Fixed in #761 . But AddConsumerHanlder in connection.go may have the same issue.