diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go
index 11a478fc2b..eb4859535c 100644
--- a/internal/util/mqclient/rmq_reader.go
+++ b/internal/util/mqclient/rmq_reader.go
@@ -32,6 +32,7 @@ func (rr *rmqReader) HasNext() bool {
 	return rr.r.HasNext()
 }
 
+// Seek seeks the reader position to id
 func (rr *rmqReader) Seek(id MessageID) error {
 	msgID := id.(*rmqID).messageID
 	return rr.r.Seek(msgID)