diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go
index 0325494ab6..11a478fc2b 100644
--- a/internal/util/mqclient/rmq_reader.go
+++ b/internal/util/mqclient/rmq_reader.go
@@ -37,6 +37,7 @@ func (rr *rmqReader) Seek(id MessageID) error {
 	return rr.r.Seek(msgID)
 }
 
+// Close closes the rocksmq reader
 func (rr *rmqReader) Close() {
 	rr.r.Close()
 }