diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go
index 966fb920cf..b165df0dc8 100644
--- a/internal/util/mqclient/pulsar_client.go
+++ b/internal/util/mqclient/pulsar_client.go
@@ -113,6 +113,7 @@ func (pc *pulsarClient) StringToMsgID(id string) (MessageID, error) {
 	return &pulsarID{messageID: pID}, nil
 }
 
+// BytesToMsgID converts []byte id to MessageID type
 func (pc *pulsarClient) BytesToMsgID(id []byte) (MessageID, error) {
 	pID, err := DeserializePulsarMsgID(id)
 	if err != nil {