2016-08-19 40 views
2

當我嘗試使用雅虎流式基準測試測試時發現這些錯誤。我嘗試將端口更改爲2080,而不是ZooKeeper「zoo.cfg」文件和kafka「server.properties」中的默認端口2181。我仍然有同樣的錯誤。任何幫助將非常感激。提前致謝。 :-)嘗試在雅虎流式基準測試上運行STORM_TEST時出錯

2792 [main] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2181 
2796 [main] ERROR o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Thread Thread[main,5,main] died 
java.lang.RuntimeException: No port is available to launch an inprocess zookeeper. 
    at org.apache.storm.zookeeper$mk_inprocess_zookeeper$fn__2124$fn__2126.invoke(zookeeper.clj:223) ~[storm-core-1.0.1.jar:1.0.1] 
    at org.apache.storm.zookeeper$mk_inprocess_zookeeper$fn__2124.invoke(zookeeper.clj:219) ~[storm-core-1.0.1.jar:1.0.1] 
    at org.apache.storm.zookeeper$mk_inprocess_zookeeper.doInvoke(zookeeper.clj:217) ~[storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.RestFn.invoke(RestFn.java:439) ~[clojure-1.7.0.jar:?] 
    at org.apache.storm.command.dev_zookeeper$_main.doInvoke(dev_zookeeper.clj:25) ~[storm-core-1.0.1.jar:1.0.1] 
    at clojure.lang.RestFn.invoke(RestFn.java:397) ~[clojure-1.7.0.jar:?] 
    at clojure.lang.AFn.applyToHelper(AFn.java:152) ~[clojure-1.7.0.jar:?] 
    at clojure.lang.RestFn.applyTo(RestFn.java:132) ~[clojure-1.7.0.jar:?] 
    at org.apache.storm.command.dev_zookeeper.main(Unknown Source) ~[storm-core-1.0.1.jar:1.0.1] 
Redis is already running... 
WARNING: send already refers to: #'clojure.core/send in namespace: setup.core, being replaced by: #'clj-kafka.new.producer/send 
{:redis-host localhost, :kakfa-brokers localhost:9092} 
Writing campaigns data to Redis. 
Error: Could not find or load main class .home.eranga.Software.kafka-0.10.0.1.config.server.properties 
Unrecognized option: --create 
Error: Could not create the Java Virtual Machine. 
Error: A fatal exception has occurred. Program will exit. 

+0

我找到了答案,第一個錯誤 '了java.lang.RuntimeException:沒有端口,可發動進程內zookeeper.' 這是因爲我們的ZooKeeper開始測試的風暴基準之前已經在運行。因此,我們首先需要停止ZooKeeper,在終端 'cd $ zookeeper_dir-version/bin /'上使用以下命令,然後使用 './zkServer.sh stop' –

+0

第二個錯誤的原因'錯誤:找不到或加載主類.home.eranga.Software.kafka-0.10.0.1.config.server.properties'是我使用的是kafka的源代碼版本。我應該使用的是卡夫卡的二進制版本。 (糟糕:-P愚蠢的我) 所以解決方案是下載二進制版本並將路徑變量設置爲該版本。我希望這可以幫助其他人:-) –

+1

也許將您的解決方案標記爲答案? –

回答

1

答案由自己在第一和第二註釋說明。

相關問題