Hi,
I have copied those jar files in storm lib folder. That errors are gone but
I have new error.
java.lang.NoClassDefFoundError: scala/runtime/AbstractFunction1$mcLI$sp
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:800)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
at
kafka.api.OffsetResponse$$anonfun$2$$anonfun$apply$1.apply(OffsetResponse.scala:37)
at
kafka.api.OffsetResponse$$anonfun$2$$anonfun$apply$1.apply(OffsetResponse.scala:33)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
at scala.collection.immutable.Range.foreach(Range.scala:81)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
at scala.collection.immutable.Range.map(Range.scala:46)
at kafka.api.OffsetResponse$$anonfun$2.apply(OffsetResponse.scala:33)
at kafka.api.OffsetResponse$$anonfun$2.apply(OffsetResponse.scala:30)
at
scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:239)
at
scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:239)
at scala.collection.immutable.Range.foreach(Range.scala:81)
at
scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:239)
at scala.collection.immutable.Range.flatMap(Range.scala:46)
at kafka.api.OffsetResponse$.readFrom(OffsetResponse.scala:30)
at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:125)
It seems that this error is related with scala. I copied the scala 2.9.2
jar files inside the storm lib directory but still have this error. Do you
guys have any idea to resolve it?
With best regards,
M Solaimani
On Mon, Apr 14, 2014 at 8:51 PM, Xing Yong <[email protected]> wrote:
> as the Exception "NoClassDefFoundError: storm/kafka/BrokerHos", i think
> the jar of storm-kafka-0.8-plus and jar of kafka should be placed in the
> lib of the storm
>
>
> 2014-04-15 5:21 GMT+08:00 M. Solaimani <[email protected]>:
>
> Hi,
>>
>> I saw this mail and tried to run the Wurstmiesters storm-kafka-0.8-plus
>> test. Here what I did:
>>
>> 1. I downloaded the Wurstmiesters storm-kafka-0.8-plus test and build
>> it by using mvn clean install.
>> 2. I had my storm cluster running. (Storm 0.9.0-rc2, Kakfka 0.8)
>> 3. I had kafka 0.8 and I run kafka servers, with zoo-keeper and created a
>> topic storm-sentence
>>
>> All the above steps running well.
>>
>> But When I run Wurstmiesters storm-kafka-0.8-plus test by the following
>> commands
>>
>> storm jar target/storm-kafka-0.8-plus-test-0.1.0-SNAPSHOT.jar
>> storm.kafka.KafkaSpoutTestTopology 10.176.148.51
>> sentences 10.176.148.51
>>
>> I got the following errors:
>>
>> Exception in thread "main" java.lang.NoClassDefFoundError:
>> storm/kafka/BrokerHos
>> ts
>> at java.lang.Class.getDeclaredMethods0(Native Method)
>> at java.lang.Class.privateGetDeclaredMethods(Class.java:2531)
>> at java.lang.Class.getMethod0(Class.java:2774)
>> at java.lang.Class.getMethod(Class.java:1663)
>> at
>> sun.launcher.LauncherHelper.getMainMethod(LauncherHelper.java:494)
>> at
>> sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:486)
>> Caused by: java.lang.ClassNotFoundException: storm.kafka.BrokerHosts
>> at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>> at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>> at java.security.AccessController.doPrivileged(Native Method)
>> at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>> at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
>> at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>> ... 6 more
>>
>>
>> At this point I am stuck. I searched the internet and it says that there
>> is some version mismatch issue? Can anyone help me please?
>>
>> With best regards,
>> M Solaimani
>>
>>
>>
>>
>>
>>
>>
>> On Mon, Apr 14, 2014 at 11:58 AM, Kashyap Mhaisekar
>> <[email protected]>wrote:
>>
>>> Wurstmiesters seems to work for me. I used storm 0.9.0 rc3
>>>
>>> Thanks,
>>> Kashyap
>>>
>>>
>>> On Monday, April 14, 2014, Trevor Madge <[email protected]> wrote:
>>>
>>>> I didn't have any luck with wurstmeister's but I've found this one (
>>>> https://github.com/HolmesNL/kafka-spout) and it works with storm 0.9.1
>>>> and kafka 0.8.1.
>>>>
>>>>
>>>> -Trevor
>>>>
>>>>
>>>>
>>>> On Fri, Apr 11, 2014 at 7:22 AM, Kashyap Mhaisekar <[email protected]
>>>> > wrote:
>>>>
>>>>> Thanks Carlos.
>>>>>
>>>>>
>>>>> On Friday, April 11, 2014, Carlos Rodriguez <[email protected]> wrote:
>>>>>
>>>>>> Hi Kashyap,
>>>>>>
>>>>>> The kafka spout provided in the storm-contrib project (
>>>>>> https://github.com/nathanmarz/storm-contrib/tree/master/storm-kafka)
>>>>>> doesnt
>>>>>> work with kafka 0.8
>>>>>>
>>>>>> The version provided by wurstmeister at
>>>>>> https://github.com/wurstmeister/storm-kafka-0.8-plus is supposed to
>>>>>> work with storm 0.9.1 and kafka 0.8.
>>>>>>
>>>>>> Regards,
>>>>>> Carlos
>>>>>>
>>>>>>
>>>>>> 2014-04-11 4:17 GMT+02:00 Kashyap Mhaisekar <[email protected]>:
>>>>>>
>>>>>>> Hi,
>>>>>>> What is the version of Kafka spout that works with storm 0.9 and
>>>>>>> kafka 0.8?
>>>>>>> The standard example doesn't throw exceptions but doesn't seem to
>>>>>>> consume messages either.
>>>>>>>
>>>>>>> Thanks,
>>>>>>> Kashyap
>>>>>>>
>>>>>>
>>>>>>
>>>>
>>
>
