Some of our tools use a consumer in Scala. You can take a look at ConsoleConsumer or MirrorMaker.
Thanks, Jun On Fri, Jun 21, 2013 at 1:16 PM, Florin Trofin <ftro...@adobe.com> wrote: > Hello Kafka wizards! > > Congratulations on achieving beta on the 0.8 release! We've been waiting > too long for it! > I have two questions regarding the high level consumer in 0.8 used from > scala: > > I found this example on how to use the high level consumer from Java: > https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example > I would like to see a similar example written in Scala. I looked under the > test folder but I didn't see something similar there (one that uses a > thread pool). I would appreciate if you can point me to an example or send > me a code snippet. > > Also, if I have a consumer for only one topic do I still need the thread > pool? Can you send me a short scala snippet on how you would initialize and > use a consumer for only one topic? > > Thanks! > > Florin
