diff options
| -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") |