From 2b43ae1609295e33f35aa4f5d1b61d60889b420c Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Sun, 3 Jan 2016 16:08:11 -0800
Subject: [PATCH] Return empty dict from KafkaConsumer.poll if no records

---
 kafka/consumer/group.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 6a5084d..44666ad 100644
--- 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):
         """