From 78d4e15c79bf4373eb04f1e1e0b7548b90d1bab7 Mon Sep 17 00:00:00 2001 From: chrislu Date: Wed, 15 Oct 2025 23:41:37 -0700 Subject: [PATCH] fmt --- weed/mq/broker/broker_grpc_lookup.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/mq/broker/broker_grpc_lookup.go b/weed/mq/broker/broker_grpc_lookup.go index 0d8e9eb8e..ec7d156f8 100644 --- a/weed/mq/broker/broker_grpc_lookup.go +++ b/weed/mq/broker/broker_grpc_lookup.go @@ -31,7 +31,7 @@ func (b *MessageQueueBroker) LookupTopicBrokers(ctx context.Context, request *mq t := topic.FromPbTopic(request.Topic) ret := &mq_pb.LookupTopicBrokersResponse{} ret.Topic = request.Topic - + // Use cached topic config to avoid expensive filer reads (26% CPU overhead!) // getTopicConfFromCache also validates broker assignments on cache miss (saves 14% CPU) conf, err := b.getTopicConfFromCache(t) @@ -39,7 +39,7 @@ func (b *MessageQueueBroker) LookupTopicBrokers(ctx context.Context, request *mq glog.V(0).Infof("lookup topic %s conf: %v", request.Topic, err) return ret, err } - + // Note: Assignment validation is now done inside getTopicConfFromCache on cache misses // This avoids 14% CPU overhead from validating on EVERY lookup ret.BrokerPartitionAssignments = conf.BrokerPartitionAssignments