Pierre Padrixe created STORM-2091:
-------------------------------------
Summary: 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)
