fix sasl.mechanism typo

Author: rnpridgeon

confluent_kafka/avro/cached_schema_registry_client.py

@@ -121,7 +121,7 @@ def _configure_basic_auth(conf):
                              .format(auth_provider, VALID_AUTH_PROVIDERS))
 
         if auth_provider == 'SASL_INHERIT':
-            if conf.pop('sasl.mechanisms', '').upper() not in ['PLAIN', 'SCRAM-SHA-256', 'SCRAM-SHA-512']:
+            if conf.pop('sasl.mechanism', '').upper() not in ['PLAIN', 'SCRAM-SHA-256', 'SCRAM-SHA-512']:
                 raise ValueError("SASL_INHERIT supports SASL mechanisms PLAIN and SCRAM only")
             auth = (conf.pop('sasl.username', ''), conf.pop('sasl.password', ''))
         elif auth_provider == 'USER_INFO':

tests/avro/test_cached_client.py

@@ -187,6 +187,7 @@ def test_basic_auth_sasl_inherit(self):
         self.client = CachedSchemaRegistryClient({
             'url': 'https://user_url:secret_url@127.0.0.1:65534',
             'basic.auth.credentials.source': 'SASL_INHERIT',
+            'sasl.mechanism': 'PLAIN',
             'sasl.username': 'user_sasl',
             'sasl.password': 'secret_sasl'
         })