Merge pull request dpkp#242 from wizzat/pr_225

wizzat · wizzat · commit c063e30a1202 · 2014-09-23T15:13:13.000-07:00
Resolve merge conflict in PR dpkp#225
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py
@@ -306,7 +306,7 @@ def _fetch(self):
                     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)
