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

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

Re: scala based service/deamon consumer example

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