diff options
| author | chrislu <chris.lu@gmail.com> | 2024-08-12 09:45:51 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-08-12 09:45:51 -0700 |
| commit | 480fcb1d032beecb56c56b5b987bca86e808430b (patch) | |
| tree | 8e0adc6651474d8e210da78148732330547cf189 | |
| parent | ff661553025bd283a9f4f3f412e9fc1f8e6fbaf6 (diff) | |
| download | seaweedfs-480fcb1d032beecb56c56b5b987bca86e808430b.tar.xz seaweedfs-480fcb1d032beecb56c56b5b987bca86e808430b.zip | |
fix build
| -rw-r--r-- | weed/mq/client/sub_client/on_each_partition.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/client/sub_client/on_each_partition.go b/weed/mq/client/sub_client/on_each_partition.go index 5dcac4eb3..58d87d9ad 100644 --- a/weed/mq/client/sub_client/on_each_partition.go +++ b/weed/mq/client/sub_client/on_each_partition.go @@ -98,7 +98,7 @@ func (sub *TopicSubscriber) onEachPartition(assigned *mq_pb.BrokerPartitionAssig switch m := resp.Message.(type) { case *mq_pb.SubscribeMessageResponse_Data: if m.Data.Ctrl != nil { - glog.V(2).Infof("subscriber %s received control from producer:%s isClose:%v", sub.SubscriberConfig.ConsumerGroup, m.Data.Ctrl.IsClose) + glog.V(2).Infof("subscriber %s received control from producer:%s isClose:%v", sub.SubscriberConfig.ConsumerGroup, m.Data.Ctrl.PublisherName, m.Data.Ctrl.IsClose) continue } executors.Execute(func() { |