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

Author: alkur-gh

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