diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:08:11 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:08:17 -0800 |
| commit | 2b43ae1609295e33f35aa4f5d1b61d60889b420c (patch) | |
| tree | 24fb26dde258e6df18b3ee84fcd8c13de803ab27 | |
| parent | 79aa0f04892ce4f5b0e27a80654e3689ac9d7e32 (diff) | |
| download | kafka-python-2b43ae1609295e33f35aa4f5d1b61d60889b420c.tar.gz | |
Return empty dict from KafkaConsumer.poll if no records
| -rw-r--r-- | kafka/consumer/group.py | 2 |
1 files changed, 1 insertions, 1 deletions
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): """ |