kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ? ?? <wangchunc...@outlook.com>
Subject NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics
Date Thu, 01 Feb 2018 06:11:16 GMT
Hi,

I am using KafkaSpout to ingest data into Storm. The versions are:

Storm-1.1.0
Storm-kafka 1.1.0
kafka_2.10-0.8.2.2

The program worked well at the beginning, but at some point the KafkaSpout threw an exception
and the program seemed stuck there afterwards. The program can proceed after restarted but
the exception recurs occasionally.

Below is the log:

java.lang.NoClassDefFoundError: Could not initialize class com.yammer.metrics.Metrics at kafka.metrics.KafkaMetricsGroup$class.newTimer(KafkaMetricsGroup.scala:85)
at kafka.consumer.FetchRequestAndResponseMetrics.newTimer(FetchRequestAndResponseStats.scala:26)
at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:35)
at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequestAndResponseStats.scala:46)
at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59)
at kafka.consumer.FetchRequestAndResponseStatsRegistry$$anonfun$2.apply(FetchRequestAndResponseStats.scala:59)
at kafka.utils.Pool.getAndMaybePut(Pool.scala:61) at kafka.consumer.FetchRequestAndResponseStatsRegistry$.getFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:63)
at kafka.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:39) at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer.scala:34)
at org.apache.storm.kafka.DynamicPartitionConnections.register(DynamicPartitionConnections.java:60)
at org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:96) at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:108)
at org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:130)
at org.apache.storm.daemon.executor$fn__4976$fn__4991$fn__5022.invoke(executor.clj:644) at
org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:748)

Could anybody tell me why?

________________________________
wangchunchao@outlook.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message