diff --git a/internal/util/rocksmq/client/rocksmq/consumer_impl.go b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
index 12edbd603c..57d7ae5c5a 100644
--- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
@@ -94,6 +94,7 @@ func (c *consumer) Topic() string {
 	return c.topic
 }
 
+// MsgMutex return the message mutex channel of consumer
 func (c *consumer) MsgMutex() chan struct{} {
 	return c.msgMutex
 }