summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-03-23 18:01:18 -0700
committerDana Powers <dana.powers@gmail.com>2019-03-23 18:01:18 -0700
commitce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f (patch)
treec45ff04c00b51ddbde2c4b940a2102db1a99ae7f
parent8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2 (diff)
downloadkafka-python-ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f.tar.gz
Update sasl configuration docstrings
-rw-r--r--kafka/admin/client.py10
-rw-r--r--kafka/client_async.py10
-rw-r--r--kafka/conn.py8
-rw-r--r--kafka/consumer/group.py10
-rw-r--r--kafka/producer/kafka.py10
5 files changed, 24 insertions, 24 deletions
diff --git a/kafka/admin/client.py b/kafka/admin/client.py
index 39f7e1a..e4219e9 100644
--- a/kafka/admin/client.py
+++ b/kafka/admin/client.py
@@ -124,13 +124,13 @@ class KafkaAdminClient(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_mechanism (str): Authentication mechanism when security_protocol
+ is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
+ PLAIN, GSSAPI, OAUTHBEARER.
sasl_plain_username (str): username for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_plain_password (str): password for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_kerberos_service_name (str): Service name to include in GSSAPI
sasl mechanism handshake. Default: 'kafka'
sasl_oauth_token_provider (AbstractTokenProvider): OAuthBearer token provider
diff --git a/kafka/client_async.py b/kafka/client_async.py
index ebd4af7..369dc3e 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -140,13 +140,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_mechanism (str): Authentication mechanism when security_protocol
+ is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
+ PLAIN, GSSAPI, OAUTHBEARER.
sasl_plain_username (str): username for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_plain_password (str): password for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_kerberos_service_name (str): Service name to include in GSSAPI
sasl mechanism handshake. Default: 'kafka'
sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI
diff --git a/kafka/conn.py b/kafka/conn.py
index 52ed9d6..9353cf2 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -176,11 +176,11 @@ class BrokerConnection(object):
metric_group_prefix (str): Prefix for metric names. Default: ''
sasl_mechanism (str): Authentication mechanism when security_protocol
is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
- PLAIN, GSSAPI. Default: PLAIN
+ PLAIN, GSSAPI, OAUTHBEARER.
sasl_plain_username (str): username for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_plain_password (str): password for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_kerberos_service_name (str): Service name to include in GSSAPI
sasl mechanism handshake. Default: 'kafka'
sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI
@@ -215,7 +215,7 @@ class BrokerConnection(object):
'state_change_callback': lambda conn: True,
'metrics': None,
'metric_group_prefix': '',
- 'sasl_mechanism': 'PLAIN',
+ 'sasl_mechanism': None,
'sasl_plain_username': None,
'sasl_plain_password': None,
'sasl_kerberos_service_name': 'kafka',
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 4b46e04..b3e182c 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -229,13 +229,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_mechanism (str): Authentication mechanism when security_protocol
+ is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
+ PLAIN, GSSAPI, OAUTHBEARER.
sasl_plain_username (str): Username for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_plain_password (str): Password for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_kerberos_service_name (str): Service name to include in GSSAPI
sasl mechanism handshake. Default: 'kafka'
sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 82df070..2a306e0 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -266,13 +266,13 @@ class KafkaProducer(object):
selector (selectors.BaseSelector): Provide a specific selector
implementation to use for I/O multiplexing.
Default: selectors.DefaultSelector
- sasl_mechanism (str): string picking sasl mechanism when security_protocol
- is SASL_PLAINTEXT or SASL_SSL. Currently only PLAIN is supported.
- Default: None
+ sasl_mechanism (str): Authentication mechanism when security_protocol
+ is configured for SASL_PLAINTEXT or SASL_SSL. Valid values are:
+ PLAIN, GSSAPI, OAUTHBEARER.
sasl_plain_username (str): username for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_plain_password (str): password for sasl PLAIN authentication.
- Default: None
+ Required if sasl_mechanism is PLAIN.
sasl_kerberos_service_name (str): Service name to include in GSSAPI
sasl mechanism handshake. Default: 'kafka'
sasl_kerberos_domain_name (str): kerberos domain name to use in GSSAPI