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
>>>>>
>>>>
>>>>
>>
