Storm1.1.0+KAFKA0.10.2.1:NoSuchMethodError&ExceptioninInitializerError

Question

我对storm和Kafka都是新手。我想运行一个开源项目:github:cestella:streaming_outliers

这个项目使用Storm0.10.0。但是，我的storm集群是Storm1.0.3，这对Storm0.10.0不起作用。

java.lang.nosuchmethoderror：org.apache.kafka.common.network.networksend.（Ljava/lang/string；Ljava/nio/bytebuffer；）V在kafka.network.requestorresponsesend.（requestorresponsesend：41）在kafka.network.requestorresponsesend.（requestorresponsesend.（requestorresponsesend：44）在kafka.network.blockingchannel.send（blockingchannel.send（blockingchannel.send：112）在kafka.consumer.simpleconsumer.liftedtree1$1（$sendrequest(SimpleConsumer.scala:83)在kafka.consumer.simpleConsumer.scala:149)在kafka.javaapi.consumer.simpleConsumer.getoffsetsbefore（simpleConsumer.scala:79)在org.apache.storm.kafka.kafkautils.getoffset（kafkautils.java:75)在org.apache.storm.kafka.kafkautils.getoffset（kafkautils.java:65)在org.apache.storm.kafka.partitionmanager（partitionmanager.java:103)在.zkCoordinator.refresh(zkCoordinator.java:98)，位于org.apache.storm.kafka.zkCoordinator.GetMyManagedPartitions（ZkCoordinator.java:69)在org.apache.storm.kafka.kafkaspout.nextTuple(kafkaspout.java:129)在org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:644)在org.apache.storm.util$async_loop$fn_557.invoke(util.clj:484)在clojure.lang.afn.run(afn.java:22)在java.lang.thread.run(thread.java:745)

而且

java.lang.ExceptioninInitializerError在kafka.metrics.kafka.metrics.kafka.consumer.fetchrequestandresponsemetrics.newTimer(kafka.consumer.fetchrequestandresponsestats.scala:90)在kafka.consumer.fetchrequestandresponsemetrics.newTimer(fetchrequestandresponsestats.scala:26)在kafka.consumer.fetchrequestandresponsestats.(fetchrequestandresponsestats.scala:35)在在Kafka.Consumer.FetchRequestandResponseStatsRegistry$$AnonFun$2.Apply(FetchRequestandResponseStats.Scala:60)在Kafka.utils.Pool$$AnonFun$GetAndResponseStats.Scala:60)在Kafka.utils.Pool$$AnonFun$GetAndResponseStats.Scala:60)在Kafka.utils.Pool$$AnonFun$GetAndResponseStats.Scala:70)在Kafka.utils.Pool应用(Pool.Scala:52)在Kafka.utils.Pool应用(Pool.Scala:52)在Kafka.utils.Pool应用(Pool.Scala:52)在Scala:44)在kafka.javaapi.consumer.SimpleCons在org.apache.storm.kafka.dynamicpartitionconnections.register（dynamicpartitionconnections.java:60)在org.apache.storm.kafka.partitionmanager（partitionmanager.java:74)在org.apache.storm.kafka.zkcoordinator.refresh（zkcoordinator.java:98)在org.apache.storm.kafka.zkcoordinator.getmymanagedpartitions（zkcoordinator.java:69)在org.apache.storm.kafka.kafka.kafka.kafka.kafkapout.nexttuple（m.daemon.executor$FN__4905$FN__4920$FN__4951.Invoke(executor.clj:644)在org.apache.storm.util$async_loop$FN__557.Invoke(util.clj:484)在clojure.lang.afn.run(afn.java:22)在java.lang.thread.run(thread.java:745)原因：java.lang.IllegalStateException：在java.lang.applicationshutdownhooks.add(applicationshutdownhooks.add(applicationshutdownhooks.java:66)在java.lang.runtime.addshutdownhook(runtime.java:211.metrics.metrics.(metrics.java:21)...21其他

而且

java.lang.NullPointerException在net.opentsdb.utils.config.GetBoolean(config.java:354)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.LoadStaticVariables（config.java:620)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.SetDefaults（config.java:532)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.(config.java:131)~[Stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.handler handler.java:127)~[stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.tsdbhandler$tsdbconfig.(tsdbhandler.java:124)~[stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.tsdbhandler.configure(tsdbhandler.java:144)~[stormjar.jar:1.6.6]在com.caseystella.analytics.outlier.outlierbolt.prepare(outlierbolt.java:63)~[stormjar.jar:1.6.6]在executor$FN__4973$FN__4986.invoke(executor.clj:791)~[storm-core-1.0.3.jar:1.0.3]在org.apache.storm.util$async_loop$FN__557.invoke(util.clj:482)[storm-core-1.0.3.jar:1.0.3]java.lang.nullPointerException在net.opentsdb.utils.config.GetBoolean(config.java:354)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.LoadStaticVariables(config.java:620)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.SetDefaults(config.java:532)~[Stormjar.jar:1.6.6]在net.opentsdb.utils.config.(config.java:131)~[Stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.handler 127)~[stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.tsdbhandler$tsdbconfig.(tsdbhandler.java:124)~[stormjar.jar:1.6.6]在com.caseystella.analytics.timeseries.tsdb.tsdbhandler.configure(tsdbhandler.java:144)~[stormjar.jar:1.6.6]在com.caseystella.analytics.outlier.outlierbolt.prepare(outlierbolt.java:63)~[stormjar.jar:1.6.6]在org.apache.storm.daemon.executor_4973$fn__4986.invoke(executor.clj:791)~[storm-core-1.0.3.jar:1.0.3]在org.apache.storm.util$async_loop$fn__557.invoke(util.clj:482)[storm-core-1.0.3.jar:1.0.3]

以下是软件包的版本。

KAFKA_Version:0.10.2.1

Kafka-客户端版本:0.10.2.1

STORM_Version:1.1.0

Storm-Kafka版本:1.1.0

flux_version:1.1.0

多谢.

Answer 1

当您的应用程序包含同一jar的多个版本（如kafka 0.10.2.1和0.10.0.1)时，不会出现这种方法错误。检查您的项目依赖关系并删除JAR的旧版本。