diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go
index 6e0b75dd62..f6c1e04a7e 100644
--- a/internal/util/mqclient/pulsar_client.go
+++ b/internal/util/mqclient/pulsar_client.go
@@ -27,6 +27,8 @@ type pulsarClient struct {
 var sc *pulsarClient
 var once sync.Once
 
+// GetPulsarClientInstance creates a pulsarClient object
+// according to the parameter opts of type pulsar.ClientOptions
 func GetPulsarClientInstance(opts pulsar.ClientOptions) (*pulsarClient, error) {
 	once.Do(func() {
 		c, err := pulsar.NewClient(opts)