From baee0fa67dda2a74a8149c9e5addf39928169568 Mon Sep 17 00:00:00 2001
From: stephenarmstrong <stephen.armstrong@linqia.com>
Date: Thu, 2 Jan 2014 19:21:10 -0800
Subject: [PATCH] Fixing issue 86

Using correct request byte size to fix issue 86's infinite loop
---
 kafka/consumer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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],