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