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 | |
parent | 52bc85dc92557188d4358c30b098d23c25a73830 (diff) | |
download | kafka-python-13752d74ef6d4c947146899668fa41c6a317bb3f.tar.gz |
Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)
-rw-r--r-- | kafka/consumer/group.py | 3 | ||||
-rw-r--r-- | kafka/producer/kafka.py | 3 |
2 files changed, 6 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): diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 5638b61..0ffc29c 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -263,6 +263,8 @@ class KafkaProducer(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' Note: Configuration parameters are described in more detail at @@ -309,6 +311,7 @@ class KafkaProducer(object): 'sasl_mechanism': None, 'sasl_plain_username': None, 'sasl_plain_password': None, + 'sasl_kerberos_service_name': 'kafka' } _COMPRESSORS = { |