From 6b801a8d2e3ec387c681100df02de49b322ffedd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lars=20J=C3=B8rgen=20Solberg?= Date: Mon, 25 Jul 2016 08:40:38 +0000 Subject: implement sasl PLAIN mechanism --- kafka/client_async.py | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index dd4df82..6e07ab0 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -70,6 +70,9 @@ class KafkaClient(object): 'selector': selectors.DefaultSelector, 'metrics': None, 'metric_group_prefix': '', + 'sasl_mechanism': None, + 'sasl_plain_username': None, + 'sasl_plain_password': None, } API_VERSIONS = [ (0, 10), @@ -150,6 +153,13 @@ class KafkaClient(object): metrics (kafka.metrics.Metrics): Optionally provide a metrics instance for capturing network IO stats. Default: None. metric_group_prefix (str): Prefix for metric names. Default: '' + sasl_mechanism (str): string picking sasl mechanism when security_protocol + is SASL_PLAINTEXT or SASL_SSL. Currently only PLAIN is supported. + Default: None + sasl_plain_username (str): username for sasl PLAIN authentication. + Default: None + sasl_plain_password (str): passowrd for sasl PLAIN authentication. + Defualt: None """ self.config = copy.copy(self.DEFAULT_CONFIG) for key in self.config: -- cgit v1.2.1