Merge pull request #345 from icapurro/fix-kafka-pull

Remove invalid keyword argument 'sleep' from kafka poll

Author: sibiryakov

frontera/contrib/messagebus/kafka/offsets_fetcher.py

@@ -178,7 +178,7 @@ def offsets(self, partitions, timestamp):
 
                 if future.exception.invalid_metadata:
                     refresh_future = self._client.cluster.request_update()
-                    self._client.poll(future=refresh_future, sleep=True)
+                    self._client.poll(future=refresh_future)
                     log.warning("Got exception %s and kept the loop", future.exception)
             if offsets:
                 return offsets