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)

Reply via email to