From 1f0f6a1a0216ba650367508be7d658d29e52cf7c Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Tue, 28 Feb 2017 10:12:02 -0800
Subject: Issue 985: Clear memory wait condition before raising Exception

---
 kafka/producer/buffer.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'kafka')

diff --git a/kafka/producer/buffer.py b/kafka/producer/buffer.py
index 422d47c..d1eeaf1 100644
--- a/kafka/producer/buffer.py
+++ b/kafka/producer/buffer.py
@@ -197,6 +197,7 @@ class SimpleBufferPool(object):
                     if self._free:
                         buf = self._free.popleft()
                     else:
+                        self._waiters.remove(more_memory)
                         raise Errors.KafkaTimeoutError(
                             "Failed to allocate memory within the configured"
                             " max blocking time")
-- 
cgit v1.2.1