You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by S Ahmed <sa...@gmail.com> on 2014/06/12 20:13:03 UTC

scala based service/deamon consumer example

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

Re: scala based service/deamon consumer example

Posted by S Ahmed <sa...@gmail.com>.

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 <wa...@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 <sa...@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
>

Re: scala based service/deamon consumer example

Posted by Guozhang Wang <wa...@gmail.com>.

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 <sa...@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