diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-16 08:40:45 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-16 08:40:45 -0800 |
| commit | f782165638c0787803e1d395bb2f6a9285ef41be (patch) | |
| tree | cc6f89f796d85de9f9c17bd652c4ddb60edf664c | |
| parent | dd1ec70e629418cf07bb30e92f04fd51c44cc459 (diff) | |
| download | seaweedfs-f782165638c0787803e1d395bb2f6a9285ef41be.tar.xz seaweedfs-f782165638c0787803e1d395bb2f6a9285ef41be.zip | |
rename
| -rw-r--r-- | weed/mq/pub_balancer/lookup.go | 2 |
1 files changed, 1 insertions, 1 deletions
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 } |