From 85b5e171d10b355af5ed9ddb80fd98286ad32596 Mon Sep 17 00:00:00 2001 From: natedogs911 Date: Tue, 17 Oct 2017 14:23:45 -0700 Subject: [PATCH] updating configs to resolve #1263 --- kafka/consumer/group.py | 3 +++ kafka/producer/kafka.py | 3 +++ 2 files changed, 6 insertions(+) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 9a1cda17a..985a73343 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 5638b61a4..0ffc29c8e 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 = {