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 >
