It looks like we will propagate the exception if the call came from an external cleanUp invocation. However, Streams also schedules a call to this method at a fixed rate, so if it fails, it would try again.
However, we do remove the lock from the `locks` map before we attempt to unlock it. If anything, it seems like we should postpone removing the lock until after we successfully unlock it and close the channel. [ Full content available at: https://github.com/apache/kafka/pull/5574 ] This message was relayed via gitbox.apache.org for [email protected]
