diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go
index 3af70c25f6..943304dcf0 100644
--- a/internal/util/mqclient/pulsar_client.go
+++ b/internal/util/mqclient/pulsar_client.go
@@ -103,6 +103,7 @@ func (pc *pulsarClient) EarliestMessageID() MessageID {
 	return &pulsarID{messageID: msgID}
 }
 
+// StringToMsgID converts the string id to MessageID type
 func (pc *pulsarClient) StringToMsgID(id string) (MessageID, error) {
 	pID, err := StringToPulsarMsgID(id)
 	if err != nil {