Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Non-blocking Kafka stream iterators


Copy link to this message
-
Re: Non-blocking Kafka stream iterators
Perfect. Thanks Jun!

Ryan
On Sun, Jan 20, 2013 at 10:16 PM, Jun Rao <[EMAIL PROTECTED]> wrote:

> Yes, see consumer.timeout.ms in http://kafka.apache.org/configuration.html
>
> Thanks,
>
> Jun
>
> On Sun, Jan 20, 2013 at 7:14 PM, Ryan LeCompte <[EMAIL PROTECTED]> wrote:
>
> > Hello all,
> >
> > Does Kafka still only support blocking stream iterstors? It would be
> great
> > to pass a timeout or have a poll() operation for fetching items. Right
> now
> > I'm always blocking in this call:
> > for (m <- stream) ...
> >
> > Thanks!
> >
> > Ryan
>