Add the sasl_kerberos_domain_name arg to KafkaAdminClient

jeffwidman · jeffwidman · commit 279a7dd85d5d · 2019-06-28T12:41:46.000-07:00
Previously the `sasl_kerberos_domain_name` was missing from the Admin
client. It is already present in the Consumer/Producer, and in all three
cases gets transparently passed down to the client.
diff --git a/kafka/admin/client.py b/kafka/admin/client.py
@@ -134,6 +134,8 @@ class KafkaAdminClient(object):
             Required if sasl_mechanism is PLAIN.
         sasl_kerberos_service_name (str): Service name to include in GSSAPI
             sasl mechanism handshake. Default: 'kafka'
+        sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI
+            sasl mechanism handshake. Default: one of bootstrap servers
         sasl_oauth_token_provider (AbstractTokenProvider): OAuthBearer token provider
             instance. (See kafka.oauth.abstract). Default: None
 
@@ -169,6 +171,7 @@ class KafkaAdminClient(object):
         'sasl_plain_username': None,
         'sasl_plain_password': None,
         'sasl_kerberos_service_name': 'kafka',
+        'sasl_kerberos_domain_name': None,
         'sasl_oauth_token_provider': None,
 
         # metrics configs
