diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-02-28 10:12:02 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-02-28 10:12:02 -0800 |
| commit | 1f0f6a1a0216ba650367508be7d658d29e52cf7c (patch) | |
| tree | d705dad18a76f4f01c079f1668b2a802abc278b4 | |
| parent | bcb4009b935fb74e3ca71206466c68ad74bc7b3c (diff) | |
| download | kafka-python-waiting_on_godot.tar.gz | |
Issue 985: Clear memory wait condition before raising Exceptionwaiting_on_godot
| -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") |