diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-21 17:02:21 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-10-21 17:02:21 -0700 |
| commit | 4dbf34abce9b4addbb304520e2f692fbaef60ae5 (patch) | |
| tree | 62c0093694d689869b393caf23786d61b68b19d3 | |
| parent | fe243c2d8db9a00a55a273c4f656f15fa1c5a81f (diff) | |
| download | kafka-python-4dbf34abce9b4addbb304520e2f692fbaef60ae5.tar.gz | |
Fixup for PR 1264 -- required to propagate configuration to BrokerConnection
| -rw-r--r-- | kafka/client_async.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 602c0c1..e36d78e 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -139,6 +139,8 @@ class KafkaClient(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' """ DEFAULT_CONFIG = { @@ -170,6 +172,7 @@ class KafkaClient(object): 'sasl_mechanism': None, 'sasl_plain_username': None, 'sasl_plain_password': None, + 'sasl_kerberos_service_name': 'kafka', } API_VERSIONS = [ (0, 10, 1), |