diff options
author | Nathanael Smith <natedogs911@gmail.com> | 2017-10-17 16:03:33 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2017-10-17 16:03:33 -0700 |
commit | 13752d74ef6d4c947146899668fa41c6a317bb3f (patch) | |
tree | 7e5b0afbc1ef4701809ae3c049c43ec1e5baa6d9 /kafka/consumer/group.py | |
parent | 52bc85dc92557188d4358c30b098d23c25a73830 (diff) | |
download | kafka-python-13752d74ef6d4c947146899668fa41c6a317bb3f.tar.gz |
Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)
Diffstat (limited to 'kafka/consumer/group.py')
-rw-r--r-- | kafka/consumer/group.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 9a1cda1..985a733 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -219,6 +219,8 @@ class KafkaConsumer(six.Iterator): 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' Note: Configuration parameters are described in more detail at @@ -274,6 +276,7 @@ class KafkaConsumer(six.Iterator): 'sasl_mechanism': None, 'sasl_plain_username': None, 'sasl_plain_password': None, + 'sasl_kerberos_service_name': 'kafka' } def __init__(self, *topics, **configs): |