HI,
I am trying to run KafkaSpout on Local cluster using - Storm
(storm-0.8.2.jar) and storm-kafka (storm-kafka-0.9.0-wip16a-scala292.jar)

I get this exception -
Caused by: java.lang.ClassNotFoundException:
backtype.storm.metric.api.IMetric
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:248)


What is the jar file I am missing? Any help?

Regards,
Kashyap

Reply via email to