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

【时间】：

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--