diff options
| -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 = { |