From a22ea165649b3510d770243f6f3809d598cb4f81 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Thu, 2 Mar 2017 11:27:07 -0800
Subject: Issue 985: Clear memory wait condition before raising Exception
 (#999)

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

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