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