producer = new Producer<Long, String>(new ProducerConfig(props));
producer.send(new KeyedMessage<Long, String>(
new String("I love kafka" + count))); however, when I run the producer, I always got the following error: Exception in thread "main" java.lang.NoSuchMethodException: com.twitter.expertsearch.indexing.jit.ExpertSearchCollectionPartitioner.<init>(kafka.utils.VerifiableProperties)
May I ask what I am missing? Is there anywhere an example java code to customize the partitioner?
finally, I made the partitioner working after changing the partition key to be string. and add the key.serializer.class to the config props. thanks for the help. On Thu, Jan 17, 2013 at 7:57 PM, Jane Wang <[EMAIL PROTECTED]> wrote:
Hmmm, so I would like to turn this into a bug for us, since at the very least the error is confusing, but I am not quite sure what was going on. At least one issue is the error doesn't make it clear whether this is for the key serializer or value serializer and could be cleaned up. Let me try to reproduce...
-Jay On Fri, Jan 18, 2013 at 9:26 AM, Jane Wang <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext