Sean McCauliff created KAFKA-4840: ------------------------------------- Summary: 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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)