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, ...)