summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--kafka/client_async.py2
-rw-r--r--kafka/producer/kafka.py3
2 files changed, 5 insertions, 0 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py
index ce1d13b..0849c7b 100644
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -136,6 +136,8 @@ class KafkaClient(object):
establish the certificate's authenticity. default: none.
ssl_keyfile (str): optional filename containing the client private key.
default: none.
+ ssl_password (str): optional password to be used when loading the
+ certificate chain. default: none.
ssl_crlfile (str): optional filename containing the CRL to check for
certificate expiration. By default, no CRL check is done. When
providing a file, only the leaf certificate will be checked against
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 3927a72..b13db86 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -216,6 +216,8 @@ class KafkaProducer(object):
establish the certificate's authenticity. default: none.
ssl_keyfile (str): optional filename containing the client private key.
default: none.
+ ssl_password (str): optional password to be used when loading the
+ certificate chain. default: none.
ssl_crlfile (str): optional filename containing the CRL to check for
certificate expiration. By default, no CRL check is done. When
providing a file, only the leaf certificate will be checked against
@@ -280,6 +282,7 @@ class KafkaProducer(object):
'ssl_certfile': None,
'ssl_keyfile': None,
'ssl_crlfile': None,
+ 'ssl_password': None,
'api_version': None,
'api_version_auto_timeout_ms': 2000,
'metric_reporters': [],