Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Avoid infinite waiting for consumer close (apache#11347)
### Motivation If there are two Events - EventA: Server close the consumer - EventB: consumer close self If EventA and EventB concurrently, then the `cnx.ctx()` has probability to be null. Which occurs a NPE, lead to infinite wait future ### Modifications If the `cnx.ctx()` is already null, we ignore the exception too.
- Loading branch information