We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 07e09c1 commit 103ac7eCopy full SHA for 103ac7e
kafka/consumer/fetcher.py
@@ -236,7 +236,7 @@ def _raise_if_offset_out_of_range(self):
236
current_out_of_range_partitions = {}
237
238
# filter only the fetchable partitions
239
- for partition, offset in self._offset_out_of_range_partitions:
+ for partition, offset in six.iteritems(self._offset_out_of_range_partitions):
240
if not self._subscriptions.is_fetchable(partition):
241
log.debug("Ignoring fetched records for %s since it is no"
242
" longer fetchable", partition)
0 commit comments