我是靠谱客的博主 大意音响,这篇文章主要介绍zookeeper中Kafka通过golang连接使用遇到的问题zookeeper中Kafka通过golang连接使用遇到的问题,现在分享给大家,希望可以做个参考。

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

问题一

复制代码
1
2
client has run out of available brokers to talk to (Is your cluster reachable?)

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

复制代码
1
2
3
4
5
6
7
8
启动: systemctl start firewalld 查看状态: systemctl status firewalld 停止:systemctl stop firewalld 禁用:systemctl disable firewalld

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

复制代码
1
2
3
4
5
6
7
8
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

问题二

复制代码
1
2
connectex: No connection could be made because the target machine actively refused it.

修改配置文件 config/server.properties

image-20220203153421604

复制代码
1
2
3
4
listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://192.168.222.129:9092

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

结果如图所示:

image-20220203153539557

最后

以上就是大意音响最近收集整理的关于zookeeper中Kafka通过golang连接使用遇到的问题zookeeper中Kafka通过golang连接使用遇到的问题的全部内容,更多相关zookeeper中Kafka通过golang连接使用遇到内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(57)

评论列表共有 0 条评论

立即
投稿
返回
顶部