diff options
| -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 10ed187..b86c8ec 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -821,7 +821,7 @@ class Fetcher(six.Iterator): # `fetch_max_bytes` option we need this shuffle # NOTE: we do have partition_data in random order due to usage # of unordered structures like dicts, but that does not - # guaranty equal distribution, and starting Python3.6 + # guarantee equal distribution, and starting in Python3.6 # dicts retain insert order. partition_data = list(partition_data.items()) random.shuffle(partition_data) |