From d6a066495b2b335f1cd20005e4a48f1f53a42e65 Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 25 Mar 2024 08:15:47 -0700 Subject: [PATCH] adjust logs --- weed/mq/broker/broker_grpc_pub.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/weed/mq/broker/broker_grpc_pub.go b/weed/mq/broker/broker_grpc_pub.go index 68bcc49b2..57a860cf1 100644 --- a/weed/mq/broker/broker_grpc_pub.go +++ b/weed/mq/broker/broker_grpc_pub.go @@ -101,14 +101,14 @@ func (b *MessageQueueBroker) PublishMessage(stream mq_pb.SeaweedMessaging_Publis for { ack, err := localTopicPartition.FollowerStream.Recv() if err != nil { - glog.Errorf("Error receiving response: %v", err) + glog.Errorf("Error receiving follower ack: %v", err) return } println("recv ack", ack.AckTsNs) if err := stream.Send(&mq_pb.PublishMessageResponse{ AckSequence: ack.AckTsNs, }); err != nil { - glog.Errorf("Error sending response %v: %v", ack, err) + glog.Errorf("Error sending publisher ack %v: %v", ack, err) return } } @@ -139,6 +139,7 @@ func (b *MessageQueueBroker) PublishMessage(stream mq_pb.SeaweedMessaging_Publis localTopicPartition.GrpcConnection.Close() } b.localTopicManager.RemoveTopicPartition(t, p) + glog.V(0).Infof("Removed local topic %v partition %v", initMessage.Topic, initMessage.Partition) } }()