Sorry, I meant to throw the exception *before* doing anything else (such as closing the channel).
I'm not familiar with these APIs, and I might be exposing my ignorance, but why should we close the channel before throwing the exception? [ Full content available at: https://github.com/apache/kafka/pull/5574 ] This message was relayed via gitbox.apache.org for [email protected]
