From ace6af5e5d2ff7b900bc694065562127b4efe8dc Mon Sep 17 00:00:00 2001 From: Cameron Boulton Date: Thu, 15 Aug 2019 16:59:08 -0700 Subject: Update conn.py --- kafka/conn.py | 3 +++ 1 file changed, 3 insertions(+) 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']) -- cgit v1.2.1