I am getting this error when constructing KafkaProducer with the kafka-python package: The code is as follows: I am using Python 3.7 and an AWS MSK cluster. Answer Solved it by just adding security_protocol=”SSL” to the KafkaProducer as follows:
I am getting this error when constructing KafkaProducer with the kafka-python package: The code is as follows: I am using Python 3.7 and an AWS MSK cluster. Answer Solved it by just adding security_protocol=”SSL” to the KafkaProducer as follows: