diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-22 00:52:55 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-22 00:52:55 -0800 |
| commit | 581cf6644cbceaf6484aa255986205ab65c4401d (patch) | |
| tree | 803d7627d3b67dab3c691cff2f337e1968380af3 | |
| parent | 7121ae9617b76aa5028dbdfcd833ca8330fc212e (diff) | |
| download | seaweedfs-581cf6644cbceaf6484aa255986205ab65c4401d.tar.xz seaweedfs-581cf6644cbceaf6484aa255986205ab65c4401d.zip | |
lookup reads from filer instead of local memory
| -rw-r--r-- | weed/mq/broker/broker_grpc_lookup.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_grpc_lookup.go b/weed/mq/broker/broker_grpc_lookup.go index fbf85dde7..0ba0b628c 100644 --- a/weed/mq/broker/broker_grpc_lookup.go +++ b/weed/mq/broker/broker_grpc_lookup.go @@ -3,6 +3,7 @@ package broker import ( "context" "fmt" + "github.com/seaweedfs/seaweedfs/weed/mq/topic" "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "google.golang.org/grpc/codes" "google.golang.org/grpc/status" @@ -26,7 +27,10 @@ func (b *MessageQueueBroker) LookupTopicBrokers(ctx context.Context, request *mq ret := &mq_pb.LookupTopicBrokersResponse{} ret.Topic = request.Topic - ret.BrokerPartitionAssignments = b.Balancer.LookupTopicPartitions(ret.Topic) + conf, err := b.readTopicConfFromFiler(topic.FromPbTopic(request.Topic)) + if err == nil { + ret.BrokerPartitionAssignments = conf.BrokerPartitionAssignments + } return ret, err } |