Hi Aditya, I'm trying to use your code for my SSL Kafka but whene I use the producer I receive the error on kafka Prodcer command:
self._wrap_ssl() File "/home/kafka/anaconda3/envs/kafka/lib/python3.8/site-packages/kafka/conn.py", line 473, in _wrap_ssl self._ssl_context.load_verify_locations(self.config['ssl_cafile'])
It seems doesn't find the CARoot file..but it is in that folder..
Can you help me? Thank you.
Hi Aditya, I'm trying to use your code for my SSL Kafka but whene I use the producer I receive the error on kafka Prodcer command:
self._wrap_ssl() File "/home/kafka/anaconda3/envs/kafka/lib/python3.8/site-packages/kafka/conn.py", line 473, in _wrap_ssl self._ssl_context.load_verify_locations(self.config['ssl_cafile'])
It seems doesn't find the CARoot file..but it is in that folder..
Can you help me? Thank you.
I think I made a typo in the code, instead of CARoot.pem it was CARoote.pem. Can you please check once.
Great it works....but self signed certificate are not good for the produce because I receive the error:
ssl.SSLCertVerificationError: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: self signed certificate in certificate chain (_ssl.c:1131)
any suggestion?
Hello,
I also have same issue, anyone has any solution for it.
Thanks