diff --git a/pkg/admin/interface.go b/pkg/admin/interface.go index 371ebddf..d989cfb7 100644 --- a/pkg/admin/interface.go +++ b/pkg/admin/interface.go @@ -244,7 +244,7 @@ func NewPulsarAdmin(conf PulsarAdminConfig) (PulsarAdmin, error) { } } else if conf.ClientCertificatePath != "" { config.AuthPlugin = auth.TLSPluginName - config.AuthParams = fmt.Sprintf("{\"tlsCertFile\": %q, \"tlsKeyFile\": %q}", conf.ClientCertificatePath, conf.ClientCertificateKeyPath) + config.AuthParams = fmt.Sprintf(`{"tlsCertFile": %q, "tlsKeyFile": %q}`, conf.ClientCertificatePath, conf.ClientCertificateKeyPath) adminClient, err = admin.New(config) if err != nil {