ah ok, " Kafka that may block if there are no new messages available."
So the iterator blocks thanks. On Thu, Jun 12, 2014 at 4:13 PM, Guozhang Wang <wangg...@gmail.com> wrote: > 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 >
