diff options
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index ed12ec0..489d96d 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -186,6 +186,13 @@ class KafkaConsumer(six.Iterator): (such as offsets) should be exposed to the consumer. If set to True the only way to receive records from an internal topic is subscribing to it. Requires 0.10+ Default: True + 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 Note: Configuration parameters are described in more detail at @@ -234,6 +241,9 @@ class KafkaConsumer(six.Iterator): 'metrics_sample_window_ms': 30000, 'selector': selectors.DefaultSelector, 'exclude_internal_topics': True, + 'sasl_mechanism': None, + 'sasl_plain_username': None, + 'sasl_plain_password': None, } def __init__(self, *topics, **configs): |