hello, you can check your .jar application with command " jar tf " to see if class kafka/api/OffsetRequest.class is part of the jar. If not you can try to copy kafka-2.9.2-0.8.0.jar (or version you are using) in storm_lib directory
Marcelo 2014-07-31 23:33 GMT+02:00 Sa Li <sa.in.v...@gmail.com>: > Hi, all > > I am running a kafka-spout code in storm-server, the pom is > > <groupId>org.apache.kafka</groupId> > <artifactId>kafka_2.9.2</artifactId> > <version>0.8.0</version> > <scope>provided</scope> > > <exclusions> > <exclusion> > <groupId>org.apache.zookeeper</groupId> > <artifactId>zookeeper</artifactId> > </exclusion> > <exclusion> > <groupId>log4j</groupId> > <artifactId>log4j</artifactId> > </exclusion> > </exclusions> > > </dependency> > > <!-- Storm-Kafka compiled --> > > <dependency> > <artifactId>storm-kafka</artifactId> > <groupId>org.apache.storm</groupId> > <version>0.9.2-incubating</version> > <scope>*compile*</scope> > </dependency> > > I can mvn package it, but when I run it > root@DO-mq-dev:/home/stuser/kafkaprj/kafka-storm-bitmap# storm jar > target/kafka-storm-bitmap-0.0.1-SNAPSHOT-jar-with-dependencies.jar > storm.artemis.KafkaConsumerTopology KafkaConsumerTopology > > > I am getting such error > > 1657 [main] INFO com.netflix.curator.framework.imps.CuratorFrameworkImpl > - Starting > 1682 [main] INFO backtype.storm.daemon.supervisor - Starting supervisor > with id a66e0c61-a951-4c1b-a43f-3fb0d12cb226 at host DO-mq-dev > 1698 [main] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread > Thread[main,5,main] died > java.lang.NoClassDefFoundError: kafka/api/OffsetRequest > at storm.artemis.kafka.KafkaConfig.<init>(KafkaConfig.java:26) > ~[kafka-storm-bitmap-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] > at > storm.artemis.kafka.trident.TridentKafkaConfig.<init>(TridentKafkaConfig.java:13) > ~[kafka-storm-bitmap-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] > at > storm.artemis.KafkaConsumerTopology.buildTopology(KafkaConsumerTopology.java:115) > ~[kafka-storm-bitmap-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] > at > storm.artemis.KafkaConsumerTopology.main(KafkaConsumerTopology.java:144) > ~[kafka-storm-bitmap-0.0.1-SNAPSHOT-jar-with-dependencies.jar:na] > Caused by: java.lang.ClassNotFoundException: kafka.api.OffsetRequest > at java.net.URLClassLoader$1.run(URLClassLoader.java:366) ~[na:1.7.0_55] > at java.net.URLClassLoader$1.run(URLClassLoader.java:355) ~[na:1.7.0_55] > at java.security.AccessController.doPrivileged(Native Method) > ~[na:1.7.0_55] > at java.net.URLClassLoader.findClass(URLClassLoader.java:354) > ~[na:1.7.0_55] > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) ~[na:1.7.0_55] > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) > ~[na:1.7.0_55] > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) ~[na:1.7.0_55] > > > > > I try to poke around online, could not find a solution for it, any idea > about that? > > > Thanks > > Alec > > > >
