diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 15fa1c9..5109523 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -698,7 +698,7 @@ class Fetcher(six.Iterator): return res def has_more(self): - return self.message_idx < len(self.messages) + return self.messages and self.message_idx < len(self.messages) class FetchManagerMetrics(object): |