Merge pull request #77 from zever/timeout-none

allow for timeout to be None in SimpleConsumer.get_messages

Author: mumrah

kafka/consumer.py

@@ -294,7 +294,8 @@ def get_messages(self, count=1, block=True, timeout=0.1):
         iterator = self.__iter__()
 
         # HACK: This splits the timeout between available partitions
-        timeout = timeout * 1.0 / len(self.offsets)
+        if timeout:
+            timeout = timeout * 1.0 / len(self.offsets)
 
         with FetchContext(self, block, timeout):
             while count > 0: