storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kunal Gupta <kunal.gu...@kartrocket.com>
Subject Re: Storm kafka spout no such method error
Date Sat, 25 Feb 2017 17:06:50 GMT
Please add Kafka maven repo in Storm lib directory

On Sat, Feb 25, 2017 at 2:57 PM, pradeep s <sreekumar.pradeep@gmail.com>
wrote:

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



-- 
*Thanks **Kunal*
*+91-9958189589*
*Senior Software Engineer*


*Bigfoot Retail Solutions Pvt Ltd.Khasra No. 264, Westend Marg, Saidulajab,
Saket 110030http://www.kartrocket.com <http://www.kartrocket.com/>*

Mime
View raw message