diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-10-04 10:10:10 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-10-04 10:10:10 -0700 |
| commit | 9450a6bfff8517371162a968f4345ffc09380bb8 (patch) | |
| tree | 90bf36f9d9e18c8dd0a0db57f310e32579d0bd09 | |
| parent | 9ee77dfdbc4aeb5723ce7ebdae76f8b7141962af (diff) | |
| download | kafka-python-9450a6bfff8517371162a968f4345ffc09380bb8.tar.gz | |
Bugfix on max_poll_records - TypeError: object of type NoneType has no len()
| -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): |