diff --git a/internal/util/rocksmq/client/rocksmq/consumer_impl.go b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
index d57c7e0050..12edbd603c 100644
--- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go
+++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go
@@ -98,6 +98,7 @@ func (c *consumer) MsgMutex() chan struct{} {
 	return c.msgMutex
 }
 
+// Chan start consume goroutine and return message channel
 func (c *consumer) Chan() <-chan ConsumerMessage {
 	c.startOnce.Do(func() {
 		c.client.wg.Add(1)