diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-09-17 15:22:21 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-09-19 21:07:14 -0700 |
| commit | e70c7b271b634e61a46ae3da54b50b8a29c24131 (patch) | |
| tree | c9896b7c6d44fce1777ce623de8d6cf45299d2f2 | |
| parent | 5b86640067218f692268045049549a434e392ae5 (diff) | |
| download | kafka-python-e70c7b271b634e61a46ae3da54b50b8a29c24131.tar.gz | |
Assert max_records > 0
| -rw-r--r-- | kafka/consumer/fetcher.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index cfed808..62190fb 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -306,6 +306,7 @@ class Fetcher(six.Iterator): """ if max_records is None: max_records = self.config['max_poll_records'] + assert max_records > 0 if self._subscriptions.needs_partition_assignment: return {}, False |