From aedd2320a9d45aaece750288701200ff77c7a1b4 Mon Sep 17 00:00:00 2001
From: alkur-gh <20610261+alkur-gh@users.noreply.github.com>
Date: Mon, 20 May 2024 20:07:22 +0500
Subject: [PATCH] fix: set admin.Connector.Dialer.SASLMechanism if TLS isn't
 enabled (#195)

---
 pkg/admin/connector.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/admin/connector.go b/pkg/admin/connector.go
index b242df8..cbda87c 100644
--- a/pkg/admin/connector.go
+++ b/pkg/admin/connector.go
@@ -131,6 +131,7 @@ func NewConnector(config ConnectorConfig) (*Connector, error) {
 
 	if !config.TLS.Enabled {
 		connector.Dialer = kafka.DefaultDialer
+		connector.Dialer.SASLMechanism = mechanismClient
 	} else {
 		var certs []tls.Certificate
 		var caCertPool *x509.CertPool