From bc765ea65b405e6037ed92938a3891a2a3a0fd5c Mon Sep 17 00:00:00 2001 From: congqixia Date: Wed, 17 Nov 2021 19:55:16 +0800 Subject: [PATCH] Fix start position for seek into a mark (#12008) Signed-off-by: Congqi Xia --- internal/msgstream/mq_msgstream.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/msgstream/mq_msgstream.go b/internal/msgstream/mq_msgstream.go index 83c90dd983..0b80a7029d 100644 --- a/internal/msgstream/mq_msgstream.go +++ b/internal/msgstream/mq_msgstream.go @@ -881,6 +881,7 @@ func (ms *MqTtMsgStream) Seek(msgPositions []*internalpb.MsgPosition) error { return fmt.Errorf("Failed to seek, error %s", err.Error()) } ms.addConsumer(consumer, mp.ChannelName) + ms.chanMsgPos[consumer] = mp // rmq seek behavior (position, ...) // pulsar seek behavior [position, ...)