diff --git a/internal/util/rocksmq/client/rocksmq/reader_impl.go b/internal/util/rocksmq/client/rocksmq/reader_impl.go
index fecf20d2af..18ad4748e3 100644
--- a/internal/util/rocksmq/client/rocksmq/reader_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go
@@ -24,6 +24,7 @@ type reader struct {
 	subscriptionRolePrefix  string
 }
 
+// newReader create a rocksmq reader from reader options
 func newReader(c *client, readerOptions *ReaderOptions) (*reader, error) {
 	if c == nil {
 		return nil, newError(InvalidConfiguration, "client is nil")