fix: set admin.Connector.Dialer.SASLMechanism if TLS isn't enabled (#195

)
segmentio · May 20, 2024 · aedd232 · aedd232
1 parent 05b587a
commit aedd232
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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