使用pykafka的时候遇到一个问题,使用Python代码向kafka发送数据的时候,通过本地可以,通过外网无法发送
当我调用pykafka中的 producer = KafkaProducer(bootstrap_servers=['X.X.X.X:9092'])
的时候报出一个异常,显示如下:
解决办法:
-
尝试修改本机
hosts
文件:将ip与云主机名对应,可能可以解决问题,但是我的这个问题并没有解决 -
修改云主机 conf:
分别修改各台服务器Kafka配置文件server.properties, 在#listeners=PLAINTEXT://:9092下添加如下一行:
advertised.listeners=PLAINTEXT://x.x.x.x:9092 (x.x.x.x为服务器对外的IP)
以上两种方式都尝试应该可以解决问题。
网友评论