diff --git a/internal/msgstream/mq_msgstream.go b/internal/msgstream/mq_msgstream.go
index b2da3386cb..0f6d014c2e 100644
--- a/internal/msgstream/mq_msgstream.go
+++ b/internal/msgstream/mq_msgstream.go
@@ -84,6 +84,7 @@ func NewMqMsgStream(ctx context.Context,
 	return stream, nil
 }
 
+// AsProducer create producer to send message to channels
 func (ms *mqMsgStream) AsProducer(channels []string) {
 	for _, channel := range channels {
 		if len(channel) == 0 {