diff options
| -rw-r--r-- | kafka/client_async.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 602c0c1..e36d78e 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -139,6 +139,8 @@ class KafkaClient(object): Default: None sasl_plain_password (str): password for sasl PLAIN authentication. Default: None + sasl_kerberos_service_name (str): Service name to include in GSSAPI + sasl mechanism handshake. Default: 'kafka' """ DEFAULT_CONFIG = { @@ -170,6 +172,7 @@ class KafkaClient(object): 'sasl_mechanism': None, 'sasl_plain_username': None, 'sasl_plain_password': None, + 'sasl_kerberos_service_name': 'kafka', } API_VERSIONS = [ (0, 10, 1), |