From 8f56ada47e71a5ebc67fff40018d3de586720f54 Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 25 Feb 2025 10:56:36 -0800 Subject: [PATCH] less logs --- weed/mq/client/sub_client/on_each_partition.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/weed/mq/client/sub_client/on_each_partition.go b/weed/mq/client/sub_client/on_each_partition.go index fbfcc3c6b..ad4cd4f50 100644 --- a/weed/mq/client/sub_client/on_each_partition.go +++ b/weed/mq/client/sub_client/on_each_partition.go @@ -8,7 +8,6 @@ import ( "github.com/seaweedfs/seaweedfs/weed/pb/mq_pb" "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" "io" - "reflect" "time" ) @@ -86,7 +85,7 @@ func (sub *TopicSubscriber) onEachPartition(assigned *mq_pb.BrokerPartitionAssig }() for { - // glog.V(0).Infof("subscriber %s/%s/%s waiting for message", sub.ContentConfig.Namespace, sub.ContentConfig.Topic, sub.SubscriberConfig.ConsumerGroup) + // glog.V(0).Infof("subscriber %s/%s waiting for message", sub.ContentConfig.Topic, sub.SubscriberConfig.ConsumerGroup) resp, err := subscribeClient.Recv() if err != nil { return fmt.Errorf("subscribe recv: %v", err) @@ -102,7 +101,7 @@ func (sub *TopicSubscriber) onEachPartition(assigned *mq_pb.BrokerPartitionAssig continue } if len(m.Data.Key) == 0 { - fmt.Printf("empty key %+v, type %v\n", m, reflect.TypeOf(m)) + // fmt.Printf("empty key %+v, type %v\n", m, reflect.TypeOf(m)) continue } onDataMessageFn(m)