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
