diff --git a/internal/util/mqclient/rmq_message.go b/internal/util/mqclient/rmq_message.go
index 21094eb5bb..2ebdaa9be6 100644
--- a/internal/util/mqclient/rmq_message.go
+++ b/internal/util/mqclient/rmq_message.go
@@ -31,6 +31,7 @@ func (rm *rmqMessage) Properties() map[string]string {
 	return nil
 }
 
+// Payload returns the payload of rocksmq message
 func (rm *rmqMessage) Payload() []byte {
 	return rm.msg.Payload
 }