異常如下:
連接信息:
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers=['localhost:9092'])
解決辦法:
只需將security_protocol="SSL" KafkaProducer security_protocol="SSL"添加到KafkaProducer即可解決此KafkaProducer ,如下所示:
from kafka import KafkaProducer
producer = KafkaProducer(security_protocol="SSL", bootstrap_servers=['localhost:9092'])
借鑒:
https://stackoom.com/question/3y2xB/kafka-python引發UnrecognizedBrokerVersion錯誤