Return empty dict from KafkaConsumer.poll if no records

2016-01-03 16:08:11 -08:00
parent 79aa0f0489
commit 2b43ae1609
1 changed files with 1 additions and 1 deletions
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -394,7 +394,7 @@ class KafkaConsumer(six.Iterator):
            remaining = timeout_ms - elapsed_ms

            if remaining <= 0:
-                break
+                return {}

    def _poll_once(self, timeout_ms):
        """