Iman, The problem may or may not be with serialization -- it looks like it can't even find the SerializationException class, which is in the same jar as every other Kafka clients class. You probably just need to adjust your CLASSPATH to make sure the kafka-clients jar is available at runtime.
-Ewen On Tue, Feb 9, 2016 at 8:54 AM, iman teimoornegad < [email protected]> wrote: > ---------- Forwarded message ---------- > From: "Dana Powers" <[email protected]> > Date: Feb 9, 2016 7:59 PM > Subject: Re: [kafka-clients] java clients problem > To: "iman teimoornegad" <[email protected]> > Cc: > > You should email [email protected] . this mailing list is used for > development of third party client libraries. > > -Dana > On Feb 9, 2016 5:12 AM, "iman teimoornegad" <[email protected]> > wrote: > > > hi i have sample producer in java but i recieve error telling me > > serialization.exception eror > > is there any working producer and consumer java class? > > here is my code: > > > > > > import org.apache.avro.Schema; > > import org.apache.avro.generic.GenericData; > > import org.apache.avro.generic.GenericRecord; > > import org.apache.kafka.clients.producer.KafkaProducer; > > import org.apache.kafka.clients.producer.ProducerRecord; > > import org.apache.kafka.common.errors.SerializationException; > > > > import java.net.UnknownHostException; > > import java.util.Properties; > > > > > > public class AvroProducer { > > > > public static void main(String[] args) throws UnknownHostException { > > > > > > Properties props = new Properties(); > > > > props.put(org.apache.kafka.clients.producer.ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, > "localhost:9092"); > > > > props.put(org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, > io.confluent.kafka.serializers.KafkaAvroSerializer.class); > > > > props.put(org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, > io.confluent.kafka.serializers.KafkaAvroSerializer.class); > > props.put("schema.registry.url", "http://localhost:8081";); > > KafkaProducer producer = new KafkaProducer(props); > > > > String key = "key1"; > > String userSchema = "{\"type\":\"record\"," + > > "\"name\":\"myrecord\"," + > > "\"fields\":[{\"name\":\"f1\",\"type\":\"string\"}]}"; > > Schema.Parser parser = new Schema.Parser(); > > Schema schema = parser.parse(userSchema); > > GenericRecord avroRecord = new GenericData.Record(schema); > > avroRecord.put("f1", "iman"); > > > > ProducerRecord record = new ProducerRecord<Object, > Object>("_schemas", key, avroRecord); > > try { > > producer.send(record); > > } catch (SerializationException e) { > > System.out.printf("fucked up"); > > } > > > > } > > } > > > > > > > > error : > > > > Exception in thread "main" java.lang.NoClassDefFoundError: > > org/apache/kafka/common/errors/SerializationException > > at java.lang.Class.forName0(Native Method) > > at java.lang.Class.forName(Class.java:195) > > at > com.intellij.rt.execution.application.AppMain.main(AppMain.java:116) > > Caused by: java.lang.ClassNotFoundException: > > org.apache.kafka.common.errors.SerializationException > > at java.net.URLClassLoader$1.run(URLClassLoader.java:366) > > at java.net.URLClassLoader$1.run(URLClassLoader.java:355) > > at java.security.AccessController.doPrivileged(Native Method) > > at java.net.URLClassLoader.findClass(URLClassLoader.java:354) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > > ... 3 more > > > > > > -- > > You received this message because you are subscribed to the Google Groups > > "kafka-clients" group. > > To unsubscribe from this group and stop receiving emails from it, send an > > email to [email protected]. > > To post to this group, send email to [email protected]. > > Visit this group at https://groups.google.com/group/kafka-clients. > > To view this discussion on the web visit > > > https://groups.google.com/d/msgid/kafka-clients/7edc95e6-af00-4ce6-80a2-92f54f1fb60b%40googlegroups.com > > < > https://groups.google.com/d/msgid/kafka-clients/7edc95e6-af00-4ce6-80a2-92f54f1fb60b%40googlegroups.com?utm_medium=email&utm_source=footer > > > > . > > For more options, visit https://groups.google.com/d/optout. > > > -- Thanks, Ewen
