diff options
| author | Cameron Boulton <cameronboulton@gmail.com> | 2019-08-15 16:59:08 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-08-16 11:00:15 -0700 |
| commit | ace6af5e5d2ff7b900bc694065562127b4efe8dc (patch) | |
| tree | e33be6e4841a6b7bb71806496bb031bbd8c7abcb | |
| parent | 2180d312c36e62c7175c112b38cbde79c3c90377 (diff) | |
| download | kafka-python-ace6af5e5d2ff7b900bc694065562127b4efe8dc.tar.gz | |
Update conn.py
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 80ece87..5ef141c 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -464,6 +464,9 @@ class BrokerConnection(object): log.info('%s: Loading SSL CA from %s', self, self.config['ssl_cafile']) self._ssl_context.load_verify_locations(self.config['ssl_cafile']) self._ssl_context.verify_mode = ssl.CERT_REQUIRED + else: + log.info('%s: Loading system default SSL CAs from %s', self, ssl.get_default_verify_paths()) + self._ssl_context.load_default_certs() if self.config['ssl_certfile'] and self.config['ssl_keyfile']: log.info('%s: Loading SSL Cert from %s', self, self.config['ssl_certfile']) log.info('%s: Loading SSL Key from %s', self, self.config['ssl_keyfile']) |