zookeeper中Kafka通过golang连接使用遇到的问题zookeeper中Kafka通过golang连接使用遇到的问题

zookeeper中Kafka通过golang连接使用遇到的问题

问题一

  client has run out of available brokers to talk to (Is your cluster reachable?)

第一步检查虚拟机的防火墙是否打开

启动： systemctl start firewalld

查看状态： systemctl status firewalld 

停止：systemctl stop firewalld 

禁用：systemctl disable firewalld

第二步开放防火墙端口或者直接关闭防火墙

firewall-cmd --add-port=9092/tcp --permanent       # 开放 9092 端口
 
firewall-cmd --reload              # 重新加载
 
firewall-cmd --list-ports     # 查看所有开放端口
总和： 
firewall-cmd --add-port=9092/tcp --permanent && firewall-cmd --reload && firewall-cmd --list-ports

问题二

  connectex: No connection could be made because the target machine actively refused it. 

修改配置文件 config/server.properties

listeners=PLAINTEXT://:9092
 
advertised.listeners=PLAINTEXT://192.168.222.129:9092  

可用vim命令修改，也可用xftp直接记事本打开修改

结果如图所示：

最后

以上就是大意音响为你收集整理的zookeeper中Kafka通过golang连接使用遇到的问题zookeeper中Kafka通过golang连接使用遇到的问题的全部内容，希望文章能够帮你解决zookeeper中Kafka通过golang连接使用遇到的问题zookeeper中Kafka通过golang连接使用遇到的问题所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。