From b485b9695c8fb1a5e87c2afe7ddb96650d1c248e Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Thu, 30 May 2024 09:15:23 -0700
Subject: [PATCH] fix passing sub follower offset

---
 weed/mq/broker/broker_grpc_sub.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 {