From f782165638c0787803e1d395bb2f6a9285ef41be Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 16 Jan 2024 08:40:45 -0800 Subject: [PATCH] rename --- weed/mq/pub_balancer/lookup.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/weed/mq/pub_balancer/lookup.go b/weed/mq/pub_balancer/lookup.go index 209261764..249aaaa1f 100644 --- a/weed/mq/pub_balancer/lookup.go +++ b/weed/mq/pub_balancer/lookup.go @@ -50,7 +50,7 @@ func (balancer *Balancer) LookupOrAllocateTopicPartitions(topic *mq_pb.Topic, pu if balancer.Brokers.IsEmpty() { return nil, ErrNoBroker } - assignments = allocateTopicPartitions(balancer.Brokers, partitionCount) + assignments = AllocateTopicPartitions(balancer.Brokers, partitionCount) balancer.OnPartitionChange(topic, assignments) return }