Assert max_records > 0
This commit is contained in:
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user