diff --git a/kafka/consumer.py b/kafka/consumer.py
index 57b5b9742..6849d0baa 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -364,7 +364,7 @@ def __iter_partition__(self, partition, offset):
             # use MaxBytes = client's bufsize since we're only
             # fetching one topic + partition
             req = FetchRequest(
-                self.topic, partition, offset, self.client.bufsize)
+                self.topic, partition, offset, fetch_size)
 
             (resp,) = self.client.send_fetch_request(
                 [req],