[ https://issues.apache.org/jira/browse/KAFKA-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sean McCauliff updated KAFKA-4840: ---------------------------------- Status: Patch Available (was: Open) > There are are still cases where producer buffer pool will not remove waiters. > ----------------------------------------------------------------------------- > > Key: KAFKA-4840 > URL: https://issues.apache.org/jira/browse/KAFKA-4840 > Project: Kafka > Issue Type: Bug > Components: clients > Affects Versions: 0.10.2.0 > Reporter: Sean McCauliff > > In BufferPool.allocate(int size, long maxTimeToBlockMs): > If a Throwable other than InterruptedException is thrown out of await() for > some reason or if there is an exception thrown in the corresponding finally > block around the await(), for example if waitTime.record(.....) throws an > exception, then the waiters are not removed from the waiters deque. > The number of available bytes are also not restored when an exception happens. -- This message was sent by Atlassian JIRA (v6.3.15#6346)