參照我之前的一篇博文Kafka學習之(二)Centos下安裝Kafka安裝了kafka並啟動,狀況並不像我之前最初的預期,報錯了,並且我在當前Linux環境下安裝的Java版本、Kafka版本都是和之前博文一樣的,第一感覺難道是因為Linux(Centos)的版本不一致???
拋開猜測,直接百度 ERROR Processor got uncaught exception,網上各種各樣的說法,有的是需要多次重啟,有的還說是java版本號問題....發現這些並不是...
正常的流程是先啟動zookeeper,然后再啟動kafka,我在公司開發機多次反復操作,出現了很多報錯,比如出現了連接超時 Unable to connect to zookeeper server within timeout: 6000(這個原因是因為我的zookeeper不知不覺自己關掉了),百度來百度去..浪費了很多時間,不過還是有收獲的。
現在解決這個問題,其實只需要給/etc/hosts添加一行配置即可。
關鍵就是這個UnkownHostException:node122
先把所有的服務干掉
ps -ef |grep kafka |grep -v grep |awk '{print $2}' | xargs kill -9
然后啟動zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
ps -ef |grep kafka ## 查看kafka的進程 netstat -ntlp |grep 9092 ##9092kafka的監聽端口
然后修改你的/etc/hosts文件,增加一行
172.16.170.122 node122 //node122就是關鍵地方,這里可別寫錯,前面就是你的ip
然后正常啟動kafka
/usr/local/kafka/bin/kafka-server-start.sh ./config/server.properties &
OK,終於成功了