From 8ce2cced47d6b4d830d5e820649d6121a915ee4a Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 19 May 2024 14:54:46 -0700 Subject: [PATCH] less logs --- weed/mq/broker/broker_grpc_sub_follow.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/weed/mq/broker/broker_grpc_sub_follow.go b/weed/mq/broker/broker_grpc_sub_follow.go index c07a98f3c..5a77ceebb 100644 --- a/weed/mq/broker/broker_grpc_sub_follow.go +++ b/weed/mq/broker/broker_grpc_sub_follow.go @@ -43,7 +43,7 @@ func (b *MessageQueueBroker) SubscribeFollowMe(stream mq_pb.SeaweedMessaging_Sub // Process the received message if ackMessage := req.GetAck(); ackMessage != nil { lastOffset = ackMessage.TsNs - println("offset", lastOffset) + // println("offset", lastOffset) } else if closeMessage := req.GetClose(); closeMessage != nil { glog.V(0).Infof("topic %v partition %v subscribe stream closed: %v", initMessage.Topic, initMessage.Partition, closeMessage) return nil