Sorry, the email sent before I typed my question. Please read below:
I wrote my own Java Consumer and Producer based off of the Kafka Producer API and High Level Consumer. Let's call them MyConsumer and MyProducer. MyProducer uses a custom Partitioner class called SimplePartitioner. In the producer.config file that I specify when I run the MirrorMaker from the command line, there is a parameter "partitioner.class". I keep getting "ClassDefNotFoundException exceptions, no matter if I put the absolute path to my SimplePartitioner.class file, a relative path, or even when I add SimplePartitioner.class to the $CLASSPATH variables created in the kafka-run-class.sh script. Here is my output error: Exception in thread "main" java.lang.ClassNotFoundException: SimplePartitioner.class 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) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:191) at kafka.utils.Utils$.createObject(Utils.scala:438) at kafka.producer.Producer.<init>(Producer.scala:60) at kafka.tools.MirrorMaker$$anonfun$1.apply(MirrorMaker.scala:116) at kafka.tools.MirrorMaker$$anonfun$1.apply(MirrorMaker.scala:106) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) at scala.collection.immutable.Range.foreach(Range.scala:81) at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) at scala.collection.immutable.Range.map(Range.scala:46) at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:106) at kafka.tools.MirrorMaker.main(MirrorMaker.scala) What is the correct value for the "partitioner.class" parameter in my producer.properties config file? On Sat, Dec 13, 2014 at 8:11 PM, Alex Melville <amelvi...@g.hmc.edu> wrote: > > Dear Kafka Devs, > > >
