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 fc9da05 commit cec1bdcCopy full SHA for cec1bdc
kafka/consumer/fetcher.py
@@ -821,7 +821,7 @@ def _create_fetch_requests(self):
821
# `fetch_max_bytes` option we need this shuffle
822
# NOTE: we do have partition_data in random order due to usage
823
# of unordered structures like dicts, but that does not
824
- # guaranty equal distribution, and starting Python3.6
+ # guarantee equal distribution, and starting in Python3.6
825
# dicts retain insert order.
826
partition_data = list(partition_data.items())
827
random.shuffle(partition_data)
0 commit comments