diff options
author | Dana Powers <dana.powers@gmail.com> | 2019-03-23 18:01:18 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2019-03-23 18:01:18 -0700 |
commit | ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f (patch) | |
tree | c45ff04c00b51ddbde2c4b940a2102db1a99ae7f | |
parent | 8e2ed3ebb45f98e71b7c77fdd52472b815bb7ad2 (diff) | |
download | kafka-python-ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f.tar.gz |
Update sasl configuration docstrings
-rw-r--r-- | kafka/admin/client.py | 10 | ||||
-rw-r--r-- | kafka/client_async.py | 10 | ||||
-rw-r--r-- | kafka/conn.py | 8 | ||||
-rw-r--r-- | kafka/consumer/group.py | 10 | ||||
-rw-r--r-- | kafka/producer/kafka.py | 10 |
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 |