[jira] [Commented] (STORM-2091) storm-kafka-client, NoSuchMethod on KafkaConsumer.subscribe

["Pierre Padrixe (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/STORM-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15486838#comment-15486838 ] 

Pierre Padrixe commented on STORM-2091:
---------------------------------------

I've built version 1.1.0 which works fine with kafka 0.10.0.1, closed this issue.

> storm-kafka-client, NoSuchMethod on KafkaConsumer.subscribe 
> ------------------------------------------------------------
>
>                 Key: STORM-2091
>                 URL: https://issues.apache.org/jira/browse/STORM-2091
>             Project: Apache Storm
>          Issue Type: Bug
>            Reporter: Pierre Padrixe
>
> Hello,
> I am currently using storm-kafka-client "1.0.2" with kafka-clients "0.10.0.1" and I am encountering the following stacktrace at runtime of my topology:
> 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:350) at org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:341) at org.apache.storm.daemon.executor$fn__7885$fn__7900$fn__7931.invoke(executor.clj:640) at org.apache.storm.util$async_loop$fn__625.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:745)
> So I checked the source code and Indeed the subscribe method takes a collection of topics in addition of the listener: https://github.com/apache/kafka/blob/0.10.0.1/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L795
> I though version 1.0.2 of storm-kafka-clients should work with kafka 0.10.0.1, do you have any idea ? Thanks.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)