diff options
| -rw-r--r-- | kafka/coordinator/assignors/range.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/assignors/range.py b/kafka/coordinator/assignors/range.py index 2fa5651..397c1b7 100644 --- a/kafka/coordinator/assignors/range.py +++ b/kafka/coordinator/assignors/range.py @@ -46,7 +46,7 @@ class RangePartitionAssignor(AbstractPartitionAssignor): if partitions is None: log.warning('No partition metadata for topic %s', topic) continue - partitions = sorted(list(partitions)) + partitions = sorted(partitions) consumers_for_topic.sort() partitions_per_consumer = len(partitions) // len(consumers_for_topic) |