Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Got exception executing Kafka Producer.


Copy link to this message
-
Got exception executing Kafka Producer.
I am executing a simple code like this:

public class FirstKafkaTester {
    public Producer<Integer, String> initProducer(){
        Properties props = new Properties();
        props.put("zk.connect", "127.0.0.1:2181");
        props.put("broker.list", "localhost:9092");
        props.put("serializer.class", "kafka.serializer.StringEncoder");
        return new Producer<Integer, String>(new ProducerConfig(props));
    }

    public void executeProducer(String topic){
        int messageNo = 1;
        Producer<Integer, String> producer = initProducer();
        String messageStr = new String("Message_" + messageNo);
        producer.send(new KeyedMessage<Integer, String>(topic, messageStr));
    }
    public static void main(String[] args) {
        FirstKafkaTester firstKafkaTester = new FirstKafkaTester();
        firstKafkaTester.executeProducer("topic_1");
    }
}
I use Kafka 0.8. I put manually to the maven in my local repository and add
dependency of yammer

        <dependency>
            <groupId>com.yammer.metrics</groupId>
            <artifactId>metrics-core</artifactId>
            <version>2.2.0</version>
        </dependency>

I got this exception:

2013-04-04 11:09:56,909 WARN  async.DefaultEventHandler
(Logging.scala:warn(89)) - Failed to send producer request with correlation
id 2 to broker 3 with data for partitions [topic_1,0]
java.lang.NoSuchMethodError: com.yammer.metrics.core.TimerContext.stop()J
 at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:36)
 at kafka.producer.SyncProducer.send(SyncProducer.scala:100)
 at
kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:243)
 at
kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$1.apply(DefaultEventHandler.scala:105)
 at
kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$1.apply(DefaultEventHandler.scala:99)
 at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80)
 at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80)
 at scala.collection.Iterator$class.foreach(Iterator.scala:631)
 at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161)
 at
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194)
 at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
 at scala.collection.mutable.HashMap.foreach(HashMap.scala:80)
 at
kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:99)
 at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72)
 at kafka.producer.Producer.send(Producer.scala:74)
 at kafka.javaapi.producer.Producer.send(Producer.scala:32)
 at kafka_eval.FirstKafkaTester.executeProducer(FirstKafkaTester.java:26)
 at kafka_eval.FirstKafkaTester.main(FirstKafkaTester.java:34)
 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
 at java.lang.reflect.Method.invoke(Method.java:597)
 at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)

Is this something wrong that I am doing?
What should I do to resolve the issue.

Thanks
Oleg.

 
+
Chris Curtin 2013-04-04, 16:43
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB