python 連接kafka異常


異常如下:

連接信息:

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錯誤


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM