首页 > 编程语言 > 详细

执行Consumer的时候发生java.net.UnknownHostException错误

时间:2016-04-08 19:39:22      阅读:553      评论:0      收藏:0      [点我收藏+]

【时间】:

2016/4/8 17:30

【问题】:

kafka执行Consumer实例的时候,发生了一下错误。

技术分享

 

kafka配置文件server.properties如下:

技术分享

 

zookeeper配置文件zoo.cfg内容如下:

技术分享

 

consumer的实现代码如下:

技术分享

 

其中静态类的定义如下:

技术分享

 

共通方法的实现如下:

技术分享

 

【调查】:

(1)查看了一下Linux防火墙设置service iptables status,发现没有关闭。不过,关闭之后问题仍然存在。

•即时生效,重启后失效

开启:service iptables start

关闭:service iptables stop

•重启后生效

开启:chkconfig iptables on

关闭:chkconfig iptables off

 

(2)查看了一下集群的工资状态。

确认zookeeper已经正常启动。

确认kafka集群已经正常启动。

 

(3)最终发现是常量定义中存在半角空格导致的。

正确:"192.168.93.128:2181,192.168.93.129:2181,192.168.93.130:2181";

错误:"192.168.93.128:2181, 192.168.93.129:2181, 192.168.93.130:2181";

 

修改之后的结果如下:

技术分享

 

【正常运行Consumer实例的截图】

技术分享

 

--END--

 

执行Consumer的时候发生java.net.UnknownHostException错误

原文:http://www.cnblogs.com/quchunhui/p/5369053.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!