SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "mykafka", "mytop1");
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("spout", new KafkaSpout(spoutConfig),1);
网上的storm-kafka例子,本地spout消费kafka,运行此例子时候,发生如下错误,求大神指点,他去找jar包中的resources文件夹,那个jar包是有的,!\resources是什么意思,是不是因为这个报错
12049 [main] INFO backtype.storm.daemon.supervisor - Starting supervisor with id 99da8caf-7235-4789-b36d-9ee0a28647e1 at host PPT03-20130716S
12131 [main] INFO backtype.storm.daemon.nimbus - Received topology submission for mytopology with conf {"topology.max.task.parallelism" nil, "topology.acker.executors" nil, "topology.kryo.register" nil, "topology.kryo.decorators" (), "topology.name" "mytopology", "storm.id" "mytopology-1-1413955598", "topology.debug" true}
12257 [main] INFO backtype.storm.daemon.nimbus - Activating mytopology: mytopology-1-1413955598
12519 [main] INFO backtype.storm.scheduler.EvenScheduler - Available slots: (["148f4e17-061e-4a92-a71b-c0172d21221a" 1024] ["148f4e17-061e-4a92-a71b-c0172d21221a" 1025] ["148f4e17-061e-4a92-a71b-c0172d21221a" 1026] ["99da8caf-7235-4789-b36d-9ee0a28647e1" 1027] ["99da8caf-7235-4789-b36d-9ee0a28647e1" 1028] ["99da8caf-7235-4789-b36d-9ee0a28647e1" 1029])
12549 [main] INFO backtype.storm.daemon.nimbus - Setting new assignment for topology id mytopology-1-1413955598: #backtype.storm.daemon.common.Assignment{:master-code-dir "C:\\Users\\ADMINI~1\\AppData\\Local\\Temp\\9e9c6fd4-afdb-467d-b052-e7cea21d124b\\nimbus\\stormdist\\mytopology-1-1413955598", :node->host {"148f4e17-061e-4a92-a71b-c0172d21221a" "PPT03-20130716S"}, :executor->node+port {[3 3] ["148f4e17-061e-4a92-a71b-c0172d21221a" 1024], [2 2] ["148f4e17-061e-4a92-a71b-c0172d21221a" 1024], [1 1] ["148f4e17-061e-4a92-a71b-c0172d21221a" 1024]}, :executor->start-time-secs {[1 1] 1413955599, [2 2] 1413955599, [3 3] 1413955599}}
12640 [Thread-5] INFO backtype.storm.daemon.supervisor - Downloading code for storm id mytopology-1-1413955598 from C:\Users\ADMINI~1\AppData\Local\Temp\9e9c6fd4-afdb-467d-b052-e7cea21d124b\nimbus\stormdist\mytopology-1-1413955598
13534 [Thread-5] INFO backtype.storm.daemon.supervisor - Copying resources at jar:file:/D:/workspace/eclipse/study/storm1/WebContent/WEB-INF/lib/kafka_2.10-0.8.1.1-javadoc.jar!/resources to C:\Users\ADMINI~1\AppData\Local\Temp\a3911a8d-3b97-4804-a82e-2632be137d39\supervisor\stormdist\mytopology-1-1413955598\resources
13546 [Thread-5] ERROR backtype.storm.event - Error when processing event
java.io.FileNotFoundException: Source 'file:\D:\workspace\eclipse\study\storm1\WebContent\WEB-INF\lib\kafka_2.10-0.8.1.1-javadoc.jar!\resources' does not exist
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:866) ~[commons-io-1.4.jar:1.4]
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:770) ~[commons-io-1.4.jar:1.4]
at org.apache.commons.io.FileUtils.copyDirectory(FileUtils.java:745) ~[commons-io-1.4.jar:1.4]
at backtype.storm.daemon.supervisor$eval6348$fn__6349.invoke(supervisor.clj:493) ~[na:na]
at clojure.lang.MultiFn.invoke(MultiFn.java:172) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.supervisor$mk_synchronize_supervisor$this__6251.invoke(supervisor.clj:325) ~[na:na]
at backtype.storm.event$event_manager$fn__2921.invoke(event.clj:39) ~[na:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_67]
13558 [Thread-5] INFO backtype.storm.util - Halting process: ("Error when processing an event")
|
|