diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-02 11:27:07 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-02 11:27:07 -0800 |
| commit | a22ea165649b3510d770243f6f3809d598cb4f81 (patch) | |
| tree | daec4798d0c256950c76c78807bf0656fcc9eb99 | |
| parent | 6aabe418c398b1e24ca3b34dd628d32cfa8ad5a6 (diff) | |
| download | kafka-python-a22ea165649b3510d770243f6f3809d598cb4f81.tar.gz | |
Issue 985: Clear memory wait condition before raising Exception (#999)
| -rw-r--r-- | kafka/producer/buffer.py | 1 |
1 files changed, 1 insertions, 0 deletions
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") |