@rajinisivaram can you please take a look? It's not clear why close(id) is not enough here. Seems like an invariant is not been maintained (the channel is either in channels or closingChannels).
[ Full content available at: https://github.com/apache/kafka/pull/5601 ] This message was relayed via gitbox.apache.org for [email protected]
