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 :
> Hi, all
>
> I am
Hello Alec,
What version of kafka are you using? 0.7.2?
And Storm Version ? 0.8.1?
The consumer you are using is prepared for kafka 0.7.2 and Storm 0.8.1.
If you are using Storm 0.9.1 (or 0.9.2) and Kafka 0.8.0 (or 0.8.1.1) you
can try this example:
https://github.com/mvalleavila/Storm-0.9.1-Kaf
ns" true,
>>>> "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m",
>>>> "storm.zookeeper.session.timeout" 2, "nimbus.reassign" true,
>>>> "topology.trident.ba
