feat: TLS authentication

streamnative · Nov 15, 2023 · 8a574a0 · 8a574a0
1 parent 4041f93
commit 8a574a0
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/pkg/admin/interface.go b/pkg/admin/interface.go
@@ -235,7 +235,6 @@ func NewPulsarAdmin(conf PulsarAdminConfig) (PulsarAdmin, error) {
 		if err != nil {
 			return nil, err
 		}
-		adminClient = admin.NewWithAuthProvider(config, oauthProvider)
 	} else if conf.Token != "" {
 		config.Token = conf.Token
 

diff --git a/pkg/connection/reconciler.go b/pkg/connection/reconciler.go
@@ -197,7 +197,7 @@ func (r *PulsarConnectionReconciler) MakePulsarAdminConfig(ctx context.Context)
 }
 
 // MakePulsarAdminConfig create pulsar admin configuration
-func (r *PulsarConnectionReconciler) MakePulsarAdminConfig(ctx context.Context, connection *resourcev1alpha1.PulsarConnection,
+func MakePulsarAdminConfig(ctx context.Context, connection *resourcev1alpha1.PulsarConnection,
 	k8sClient client.Client) (*admin.PulsarAdminConfig, error) {
 	if connection.Spec.AdminServiceURL == "" && connection.Spec.AdminServiceSecureURL == "" {
 		return nil, fmt.Errorf("adminServiceURL or adminServiceSecureURL must not be empty")