There are few problems with this way of closing the connections. `channelInactive()` is supposed to be called by Netty when the connection gets closed. With the current approache the original TCP connection will stay open and the broker will still have registered the producer/consumer as connected.
The right approach here should be to close all the connections in the `ConnectionPool`. That will be triggering the reconnections for all producers/consumers. [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2543 ] This message was relayed via gitbox.apache.org for [email protected]
