From 36b53f487778e919dfe6a5940dc25c552444cc7c Mon Sep 17 00:00:00 2001
From: the-sea <huhaiyang2@huawei.com>
Date: Fri, 31 Aug 2018 21:03:26 +0800
Subject: add kerberos domain name config for gssapi sasl mechanism handshake
 (#1542)

---
 kafka/client_async.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'kafka/client_async.py')

diff --git a/kafka/client_async.py b/kafka/client_async.py
index c0072ae..5a161bb 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -145,6 +145,8 @@ class KafkaClient(object):
             Default: None
         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
     """
 
     DEFAULT_CONFIG = {
@@ -180,6 +182,7 @@ class KafkaClient(object):
         'sasl_plain_username': None,
         'sasl_plain_password': None,
         'sasl_kerberos_service_name': 'kafka',
+        'sasl_kerberos_domain_name': None
     }
 
     def __init__(self, **configs):
-- 
cgit v1.2.1