You may want to read this wiki: https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
Guozhang On Thu, Jun 12, 2014 at 11:13 AM, S Ahmed <sahmed1...@gmail.com> wrote: > Is there a simple example (scala preferred) where there is a consumer that > is written to run as a deamon i.e. it keeps as open connection into a > broker and reads off new messages > -- -- Guozhang
