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)