解决远程kafka本地无法连接问题
解决远程kafka本地无法连接问题
·
前提:kafka/zookeeper服务部署阿里云服务器centos7
开发环境idea启动消费者连接kafka失败,提示如下,证明kafka客户端连接不上
查看kafka日志发现,报警是因为topic刚创建、消费已开始、但是还没有生产者推送消息过来、对应topic没有任何offset的记录导致的,证明网络部分是没有问题的,通常就是配置不当导致。
1.处理如下,开启远程服务器安全组入网方向(kafka默认9092,如不同则开启相对应)
2.修改kafka/config/server.properties 配置文件,添加以下两行
#配置内外网访问 2022年4月16日23:00:59
listeners=PLAINTEXT://私网ip:9092
advertised.listeners=PLAINTEXT://公网ip:9092
3.开启防火墙并添加端口
#开启防火墙
systemctl start firewalld
#开启2181(zk,如果需要向外连接zk则需要)
firewall-cmd --zone=public --add-port=2181/tcp --permanent
#开启开启9092(kafka)
firewall-cmd --zone=public --add-port=9092/tcp --permanent
#重启防火墙
firewall-cmd --reload
#查看已经开放的端口
firewall-cmd --list-ports
#查看是否开启成功
[root@uebuZ config]# firewall-cmd --list-ports
8500/tcp 2181/tcp 9092/tcp
#证明防火墙(9092)已经成功开启
4.停止并重启kafka服务
./kafka-server-stop.sh
./kafka-server-start.sh -daemon ../config/server.properties
更多推荐
已为社区贡献1条内容
所有评论(0)