diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-30 09:15:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-30 09:15:23 -0700 |
| commit | b485b9695c8fb1a5e87c2afe7ddb96650d1c248e (patch) | |
| tree | cc49276038ff20fc7c3b33b9ebbf97503d636709 | |
| parent | f7b818483a7b8c96720fd625f689691e0f97b867 (diff) | |
| download | seaweedfs-b485b9695c8fb1a5e87c2afe7ddb96650d1c248e.tar.xz seaweedfs-b485b9695c8fb1a5e87c2afe7ddb96650d1c248e.zip | |
fix passing sub follower offset
| -rw-r--r-- | weed/mq/broker/broker_grpc_sub.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_grpc_sub.go b/weed/mq/broker/broker_grpc_sub.go index 126322cd9..68a80398d 100644 --- a/weed/mq/broker/broker_grpc_sub.go +++ b/weed/mq/broker/broker_grpc_sub.go @@ -115,7 +115,7 @@ func (b *MessageQueueBroker) SubscribeMessage(stream mq_pb.SeaweedMessaging_Subs if err := subscribeFollowMeStream.Send(&mq_pb.SubscribeFollowMeRequest{ Message: &mq_pb.SubscribeFollowMeRequest_Ack{ Ack: &mq_pb.SubscribeFollowMeRequest_AckMessage{ - TsNs: lastOffset, + TsNs: currentLastOffset, }, }, }); err != nil { |