前提: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 

  

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐