i have got it working with graphite.Let me know if you still need any help with this.
Regards, Pushkar On Sun, Feb 9, 2014 at 10:40 PM, Jun Rao <jun...@gmail.com> wrote: > You will need to the metrics-graphite jar ( > http://mvnrepository.com/artifact/com.yammer.metrics/metrics-graphite) > > Thanks, > > Jun > > > On Sat, Feb 8, 2014 at 12:40 PM, Alex Gray <alex.g...@inin.com> wrote: > > > With the help of my colleague, we got a little further. > > I created a jar from the following source code (see below), but I get a > > NoClassDefFoundError when I try to start kafka. > > I somehow need to tell Kafka to use my custom reporter. > > > > In my server.properties, I'm trying to tell it to use my custom reporter: > > kafka.metrics.reporters=kafka.metrics.KafkaGraphiteReporter > > > > And the jar file lives in /libs, so I know it's in the class path when > > kafka starts (maybe it's not in the correct order in the class path?). > > > > Here is the error from kafka when I try to start it: > > java.lang.NoClassDefFoundError: com/yammer/metrics/reporting/ > > GraphiteReporter > > at kafka.metrics.KafkaGraphiteReporter.init( > > KafkaGraphiteReporter.java:15) > > at kafka.metrics.KafkaMetricsReporter$$anonfun$ > > startReporters$1.apply(KafkaMetricsReporter.scala:60) > > at kafka.metrics.KafkaMetricsReporter$$anonfun$ > > startReporters$1.apply(KafkaMetricsReporter.scala:58) > > at scala.collection.IndexedSeqOptimized$class. > > foreach(IndexedSeqOptimized.scala:34) > > at scala.collection.mutable.WrappedArray.foreach( > > WrappedArray.scala:32) > > at kafka.metrics.KafkaMetricsReporter$.startReporters( > > KafkaMetricsReporter.scala:58) > > at kafka.Kafka$.main(Kafka.scala:36) > > at kafka.Kafka.main(Kafka.scala) > > > > Here is the source code. It's not really doing anything at the moment... > > I just want kafka to use it when it starts up... > > ===================== > > package kafka.metrics; > > import java.util.Map; > > import java.util.concurrent.TimeUnit; > > > > import kafka.utils.VerifiableProperties; > > > > import com.yammer.metrics.Metrics; > > import com.yammer.metrics.core.Metric; > > import com.yammer.metrics.core.MetricName; > > import com.yammer.metrics.reporting.GraphiteReporter; > > > > public class KafkaGraphiteReporter implements KafkaMetricsReporter, > > Runnable { > > > > public void init(VerifiableProperties arg0) { > > GraphiteReporter.enable(1, TimeUnit.MINUTES, > > "my.graphite.server.com", > > 2003); > > System.out.println("Graphite init..."); > > Thread t = new Thread(this); > > t.setDaemon(true); > > t.setName("graphitebg"); > > t.start(); > > } > > > > public void run() { > > try { > > while(true) { > > try { > > Thread.sleep(3000); > > } catch (InterruptedException e) { > > > > e.printStackTrace(); > > } > > System.out.println("Graphite background > > thread executing"); > > GraphiteReporter.enable(1, > > TimeUnit.MINUTES, > > "my.graphite.server.com > ", > > 2003); > > > > Map<MetricName, Metric> allMetrics = > > Metrics.defaultRegistry().allMetrics(); > > for (MetricName key : > allMetrics.keySet()) > > { > > System.out.println(key + "=" + > > allMetrics.get(key).toString()); > > } > > } > > } catch (Exception e) { > > e.printStackTrace(); > > } > > } > > } > > > > ===================== > > > > if you have any thoughts on getting this to work, that would be awesome. > > > > Thanks, > > > > Alex > > > > >
