From d505b5b52c90275accd1786ff5d045dad144630b Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Fri, 28 Jun 2019 12:34:03 -0700 Subject: [PATCH] Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient` 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. --- kafka/admin/client.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kafka/admin/client.py b/kafka/admin/client.py index e23b15e69..4fd8a1b33 100644 --- 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