diff --git a/internal/util/mqclient/pulsar_client.go b/internal/util/mqclient/pulsar_client.go
index f6c1e04a7e..e5ae08a61f 100644
--- a/internal/util/mqclient/pulsar_client.go
+++ b/internal/util/mqclient/pulsar_client.go
@@ -33,7 +33,7 @@ func GetPulsarClientInstance(opts pulsar.ClientOptions) (*pulsarClient, error) {
 	once.Do(func() {
 		c, err := pulsar.NewClient(opts)
 		if err != nil {
-			log.Error("Set pulsar client failed, error", zap.Error(err))
+			log.Error("Failed to set pulsar client: ", zap.Error(err))
 			return
 		}
 		cli := &pulsarClient{client: c}