I had some trouble with maven dependencies when i tried to get a simple round trip test going. I worked past those and made my test available here: https://github.com/buildlackey/cep/tree/master/kafka
it should run out of the box. -cb On Thu, Nov 7, 2013 at 5:35 PM, S L <slouie.at.w...@gmail.com> wrote: > Hi, > > This might be a really, really simple question but how do I get my test > Kafka program working out of the box? I followed the directions from > http://kafka.apache.org/documentation.html#quickstart. I started zk, the > server, the producer and consumer. I played with the producer, sending > msgs to the consumer, which I saw show up in its terminal. This was to the > "page_visits" topic, as specified in the example program. > > I then went to > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Exampleand > copied the files into netbeans and built it. I also added jar files > kafka-assembly-0.8.0-deps.jar and kafka_2.8.0-0.8.0-beta1.jar to make the > build work if that makes a difference. > > Anyway, I then ran java -jar myjar.jar. I expected to see a message show > up in the consumer, but nothing shows up. I sent another msg from the > producer just to make sure the consumer was still connected, which it was > b/c the consumer received it. > > I'm at wits end. I know this is an extremely simple question and > everything looks identical to the links above and should be working. > However, I'm not getting a message in the consumer. Much thanks for any > help you can give me. I'm about to ram my head into a wall. > -- Chris Bedford Founder & Lead Lackey Build Lackey Labs: http://buildlackey.com Go Grails!: http://blog.buildlackey.com