diff options
| -rw-r--r-- | kafka/consumer/simple.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index dcc71a9..b74924b 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -305,7 +305,7 @@ class SimpleConsumer(Consumer): if self.max_buffer_size is None: buffer_size *= 2 else: - buffer_size = max(buffer_size * 2, + buffer_size = min(buffer_size * 2, self.max_buffer_size) log.warn("Fetch size too small, increase to %d (2x) " "and retry", buffer_size) |