How To Specify partioner.class for Mirrormaker?

2014-12-13 Thread Alex Melville
Dear Kafka Devs,

Re: How To Specify partioner.class for Mirrormaker?

2014-12-13 Thread Alex Melville
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 produc

csv files to kafka

2014-12-13 Thread kishore kumar
HI Experts, I want to load csv files to kafka, anybody help me to write javacode for this? -- Thanks, Kishore.