diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-19 14:54:46 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-19 14:54:46 -0700 |
| commit | 8ce2cced47d6b4d830d5e820649d6121a915ee4a (patch) | |
| tree | 786676533e9b60653e8975c70f247443c1387107 | |
| parent | c6db3f31a18e2b0181768c87740547594d4c5011 (diff) | |
| download | seaweedfs-8ce2cced47d6b4d830d5e820649d6121a915ee4a.tar.xz seaweedfs-8ce2cced47d6b4d830d5e820649d6121a915ee4a.zip | |
less logs
| -rw-r--r-- | weed/mq/broker/broker_grpc_sub_follow.go | 2 |
1 files changed, 1 insertions, 1 deletions
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 |