diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go
index 426cc26392..850f0cd9c7 100644
--- a/internal/util/mqclient/rmq_client.go
+++ b/internal/util/mqclient/rmq_client.go
@@ -62,6 +62,7 @@ func (rc *rmqClient) Subscribe(options ConsumerOptions) (Consumer, error) {
 	return rConsumer, nil
 }
 
+// EarliestMessageID returns the earliest message ID for rmq client
 func (rc *rmqClient) EarliestMessageID() MessageID {
 	rID := rocksmq.EarliestMessageID()
 	return &rmqID{messageID: rID}