summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNathanael Smith <natedogs911@gmail.com>2017-10-17 16:03:33 -0700
committerDana Powers <dana.powers@gmail.com>2017-10-17 16:03:33 -0700
commit13752d74ef6d4c947146899668fa41c6a317bb3f (patch)
tree7e5b0afbc1ef4701809ae3c049c43ec1e5baa6d9
parent52bc85dc92557188d4358c30b098d23c25a73830 (diff)
downloadkafka-python-13752d74ef6d4c947146899668fa41c6a317bb3f.tar.gz
Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#1264)
-rw-r--r--kafka/consumer/group.py3
-rw-r--r--kafka/producer/kafka.py3
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 = {