Hi,
I am using Storm 1.0.3 and kafka 0.10.1.1 and initialising KafkaSpout using
storm-kafka-client
https://github.com/apache/storm/blob/master/docs/storm-kafka-client.md
Dependencies used are

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.10.1.1</version>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-kafka-client</artifactId>
<version>1.0.3</version>
</dependency>

While starting the topology spout is failing by below error
java.lang.*NoSuchMethodError*:
org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/util/List;Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;)V
        at
org.apache.storm.kafka.spout.KafkaSpout.subscribeKafkaConsumer(KafkaSpout.java:360)
~[stormjar.jar:?]
        at
org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:351)
~[stormjar.jar:?]
        at
org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:639)
~[storm-core-1.0.3.jar:1.0.3]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484)
[storm-core-1.0.3.jar:1.0.3]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]

Regards
Pradeep S

Reply via email to