diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
index 706d7fdc66f93b867deec7b40e4b4b2d33bfad5d..32157c7aebbb11f971be6283c70d1b5cb37f5da1 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@@ -1067,6 +1067,7 @@ func (rmq *rocksmq) HasNext(topicName string, readerName string, messageIDInclus
 	return reader.HasNext(messageIDInclusive)
 }
 
+// CloseReader close a reader
 func (rmq *rocksmq) CloseReader(topicName string, readerName string) {
 	if rmq.isClosed() {
 		return