使用pykafka的時(shí)候遇到一個(gè)問(wèn)題,使用Python代碼向kafka發(fā)送數(shù)據(jù)的時(shí)候嚼贡,通過(guò)本地可以同诫,通過(guò)外網(wǎng)無(wú)法發(fā)送
當(dāng)我調(diào)用pykafka中的 producer = KafkaProducer(bootstrap_servers=['X.X.X.X:9092'])
的時(shí)候報(bào)出一個(gè)異常,顯示如下:
image.png
解決辦法:
嘗試修改本機(jī)
hosts
文件:將ip與云主機(jī)名對(duì)應(yīng)叮盘,可能可以解決問(wèn)題霹俺,但是我的這個(gè)問(wèn)題并沒(méi)有解決修改云主機(jī) conf:
分別修改各臺(tái)服務(wù)器Kafka配置文件server.properties, 在#listeners=PLAINTEXT://:9092下添加如下一行:
advertised.listeners=PLAINTEXT://x.x.x.x:9092 (x.x.x.x為服務(wù)器對(duì)外的IP)
以上兩種方式都嘗試應(yīng)該可以解決問(wèn)題愈魏。