From 8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2 Mon Sep 17 00:00:00 2001 From: Phong Pham Date: Fri, 22 Mar 2019 21:24:29 -0400 Subject: Support SASL OAuthBearer Authentication (#1750) --- kafka/consumer/group.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'kafka/consumer/group.py') diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index c107f5a..4b46e04 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -240,6 +240,8 @@ class KafkaConsumer(six.Iterator): sasl mechanism handshake. Default: 'kafka' sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI sasl mechanism handshake. Default: one of bootstrap servers + sasl_oauth_token_provider (AbstractTokenProvider): OAuthBearer token provider + instance. (See kafka.oauth.abstract). Default: None Note: Configuration parameters are described in more detail at @@ -299,7 +301,8 @@ class KafkaConsumer(six.Iterator): 'sasl_plain_username': None, 'sasl_plain_password': None, 'sasl_kerberos_service_name': 'kafka', - 'sasl_kerberos_domain_name': None + 'sasl_kerberos_domain_name': None, + 'sasl_oauth_token_provider': None } DEFAULT_SESSION_TIMEOUT_MS_0_9 = 30000 -- cgit v1.2.1