diff --git a/pkg/kgo/group_balancer.go b/pkg/kgo/group_balancer.go index cfc36f17..a84a68f1 100644 --- a/pkg/kgo/group_balancer.go +++ b/pkg/kgo/group_balancer.go @@ -293,7 +293,7 @@ func (*rangeBalancer) balance(members []groupMember, topics map[string]int32) ba partitions[i] = int32(i) } numParts := len(partitions) - div, rem := numParts/len(members), numParts%len(members) + div, rem := numParts/len(potentialConsumers), numParts%len(potentialConsumers) var consumerIdx int for len(partitions) > 0 {