diff --git a/internal/util/mqclient/rmq_message.go b/internal/util/mqclient/rmq_message.go
index ddd12ed961..21094eb5bb 100644
--- a/internal/util/mqclient/rmq_message.go
+++ b/internal/util/mqclient/rmq_message.go
@@ -35,6 +35,7 @@ func (rm *rmqMessage) Payload() []byte {
 	return rm.msg.Payload
 }
 
+// ID returns the id of rocksmq message
 func (rm *rmqMessage) ID() MessageID {
 	return &rmqID{messageID: rm.msg.MsgID}
 }