From a2b8add4e2d006d79caeacbb3e0fd84acce4e740 Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Wed, 20 Oct 2021 10:54:43 +0800 Subject: [PATCH] [skip ci]Improve error message in mqclient (#10240) Signed-off-by: Xiangyu Wang --- internal/util/mqclient/pulsar_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}