【時間】：

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

?

轉載于:https://www.cnblogs.com/quchunhui/p/5369053.html

總結

以上是生活随笔為你收集整理的【坑】执行Consumer的时候发生java.net.UnknownHostException错误的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。