Merge pull request dpkp#242 from wizzat/pr_225

Resolve merge conflict in PR dpkp#225

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)