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 <lecom...@gmail.com> wrote: > Perfect. Thanks Jun! > > Ryan > > > On Sun, Jan 20, 2013 at 10:16 PM, Jun Rao <jun...@gmail.com> 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 <lecom...@gmail.com> > 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 > > >
