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
navneet sharma 2013-01-21, 07:03
Is there any property to make consumer work for lets say only 10 mins (ie
some kind of timer)
So, i want to close the consumer after 10 mins reading from broker..

Thanks,
Navneet Sharma
On Mon, Jan 21, 2013 at 11:48 AM, Ryan LeCompte <[EMAIL PROTECTED]> wrote:

> 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
> >
>