Hi Thomas, org.apache.kafka.common.network.NetworkSend - is class from Kafka client library. Before Kafka 0.9, constructor for that class had "int" as first argument. Are you sure that you have only one version of kafka-client jar in your classpath?
Regards, Viktor On 6 September 2016 at 05:45, Thomas Cristanis <[email protected]> wrote: > I'm getting this error when running a topology that uses a KafkaSpout. > Is anyone having this problem? > You have no idea what can be? > > 31455 [Thread-66-kafka-spout-executor[21 21]] INFO > o.a.s.k.PartitionManager - Read partition information from: > /teste/35f1a742-784e-4a0a-9222-d7621aa8884b/partition_0 --> null > > log4j:WARN No appenders could be found for logger (kafka.consumer. > SimpleConsumer). > > log4j:WARN Please initialize the log4j system properly. > > log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for > more info. > > 31540 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Async > loop died! > > java.lang.NoSuchMethodError: org.apache.kafka.common. > network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V > > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.network.BlockingChannel.send(BlockingChannel.scala:112) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$ > $sendRequest(SimpleConsumer.scala:83) ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149) > ~[kafka_2.11-0.10.0.0.jar:?] > > at > kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79) > ~[kafka_2.11-0.10.0.0.jar:?] > > at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.PartitionManager.<init>(Partit > ionManager.java:103) ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoord > inator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at > org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648) > ~[storm-core-1.0.2.jar:1.0.2] > > at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484) > [storm-core-1.0.2.jar:1.0.2] > > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] > > at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66] > > 31549 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.d.executor - > > java.lang.NoSuchMethodError: org.apache.kafka.common. > network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V > > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:44) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.network.BlockingChannel.send(BlockingChannel.scala:112) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:98) > ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$ > $sendRequest(SimpleConsumer.scala:83) ~[kafka_2.11-0.10.0.0.jar:?] > > at kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149) > ~[kafka_2.11-0.10.0.0.jar:?] > > at > kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79) > ~[kafka_2.11-0.10.0.0.jar:?] > > at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.PartitionManager.<init>(Partit > ionManager.java:103) ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoord > inator.java:69) ~[storm-kafka-1.0.2.jar:1.0.2] > > at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129) > ~[storm-kafka-1.0.2.jar:1.0.2] > > at > org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648) > ~[storm-core-1.0.2.jar:1.0.2] > > at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484) > [storm-core-1.0.2.jar:1.0.2] > > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] > > at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66] > > 31614 [Thread-66-kafka-spout-executor[21 21]] ERROR o.a.s.util - Halting > process: ("Worker died") > > java.lang.RuntimeException: ("Worker died") > > at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) > [storm-core-1.0.2.jar:1.0.2] > > at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] > > at org.apache.storm.daemon.worker$fn__8659$fn__8660.invoke(worker.clj:761) > [storm-core-1.0.2.jar:1.0.2] > > at org.apache.storm.daemon.executor$mk_executor_data$fn__ > 7875$fn__7876.invoke(executor.clj:274) [storm-core-1.0.2.jar:1.0.2] > > at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:494) > [storm-core-1.0.2.jar:1.0.2] > > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] > > at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66] > -- With best regards, Viktor M. Pishchulin
