在lua连接Kafka的异常处理：send() failed (111: Connection refused) while resolving

Lua连接Kafka的时候，Kafka无法消费topic中的数据

1.首先确保zookeeper已经启动，而且nginx.conf中已经配置 好lua的路径

2.然后重启nginx

3.如果还是不行，在kafka中的config/server.properties配置文件中更改以下信息

注意：主要是更改配置文件中的映射地址为ip

listeners=PLAINTEXT://192.168.XXX.XXX:9092
host.name=192.168.XXX.XXX   --使用IP地址

4.然后记住重启！！！！
5.如果还是不好，就可能因为zookeeper中关于kafka的注册信息过期的问题，需要重新注册，执行下列操作：

注意：下面的操作都是在zookeeper安装目录下进行的

bin/zkCli.sh  	    --打开zookeeper的客户端
ls /				--展示zookeeper的一些注册信息
rmr /brokers		    --此时会出现很多的文件，看是否有brokers，这是Kafka的注册信息，然后将这个文件删除

6.最后在重新启动Kafka集群，使其自动将信息注册到zookeeper。
中间我在查看Lua中nginx的错误日志，发现如下错误，这个就是因为注册信息过期的问题，经过上面的步骤就可以解决了

[error] 28779#0: send() failed (111: Connection refused) while resolving, resolver: 127.0.0.1:53

• 点赞
• 收藏
• 分享
• 文章举报