diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-25 08:15:47 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-25 08:15:47 -0700 |
| commit | d6a066495b2b335f1cd20005e4a48f1f53a42e65 (patch) | |
| tree | b3fd37aee6843aab83f12fa006b134df957789fb | |
| parent | 1b1b96ea1ef00d8d5837954056dec66c35bb9589 (diff) | |
| download | seaweedfs-d6a066495b2b335f1cd20005e4a48f1f53a42e65.tar.xz seaweedfs-d6a066495b2b335f1cd20005e4a48f1f53a42e65.zip | |
adjust logs
| -rw-r--r-- | weed/mq/broker/broker_grpc_pub.go | 5 |
1 files 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) } }() |