diff options
| author | Phong Pham <pt2pham@users.noreply.github.com> | 2019-03-22 21:24:29 -0400 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-03-22 18:24:29 -0700 |
| commit | 8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2 (patch) | |
| tree | 3e01a6011767468010734d603bcfdf4c64f7afa5 /kafka/producer/kafka.py | |
| parent | d032844ad945b6e99845c40cfe08e026a56d332a (diff) | |
| download | kafka-python-8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2.tar.gz | |
Support SASL OAuthBearer Authentication (#1750)
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 5 |
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 = { |