summaryrefslogtreecommitdiff
path: root/kafka/producer/kafka.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/producer/kafka.py')
-rw-r--r--kafka/producer/kafka.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index e4d5929..82df070 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -277,6 +277,8 @@ class KafkaProducer(object):
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
@@ -328,7 +330,8 @@ class KafkaProducer(object):
'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
}
_COMPRESSORS = {