Closes #22

Removed get_messages API, added test for get_pending

1 files changed, 0 insertions, 20 deletions

diff --git a/kafka/consumer.py b/kafka/consumer.py
index f41488f..603ea36 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -155,26 +155,6 @@ class SimpleConsumer(object):
                 assert resp.error == 0
             self.count_since_commit = 0
 
-    def get_messages(self, count=1):
-        """
-        Get the specified number of messages
-
-        count: maximum number of messages to be fetched
-        """
-        if not hasattr(self, '_iterator'):
-            self._iterator = iter(self)
-
-        msgs = []
-        while count > 0:
-            try:
-                msgs.append(self._iterator.next())
-                count -= 1
-            except StopIteration:
-                delattr(self, '_iterator')
-                break
-
-        return msgs
-
     def __iter__(self):
         """
         Create an iterate per partition. Iterate through them calling next() until they are