summaryrefslogtreecommitdiff
path: root/kafka/producer/kafka.py
diff options
context:
space:
mode:
authorthe-sea <huhaiyang2@huawei.com>2018-08-31 21:03:26 +0800
committerDana Powers <dana.powers@gmail.com>2018-08-31 06:03:26 -0700
commit36b53f487778e919dfe6a5940dc25c552444cc7c (patch)
treeeeb843fbdaf059c964a5f16b5b8ba82735ea43d1 /kafka/producer/kafka.py
parenta7d3063d5fa1c3cb2a76c16231bb3028a6f8cde9 (diff)
downloadkafka-python-36b53f487778e919dfe6a5940dc25c552444cc7c.tar.gz
add kerberos domain name config for gssapi sasl mechanism handshake (#1542)
Diffstat (limited to 'kafka/producer/kafka.py')
-rw-r--r--kafka/producer/kafka.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index d8fb5dc..24b58fe 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -270,6 +270,8 @@ class KafkaProducer(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
Note:
Configuration parameters are described in more detail at
@@ -319,7 +321,8 @@ class KafkaProducer(object):
'sasl_mechanism': None,
'sasl_plain_username': None,
'sasl_plain_password': None,
- 'sasl_kerberos_service_name': 'kafka'
+ 'sasl_kerberos_service_name': 'kafka',
+ 'sasl_kerberos_domain_name': None
}
_COMPRESSORS = {